Skip to content

Commit

Permalink
Merge pull request #1637 from crossplane-contrib/backport-1636-to-rel…
Browse files Browse the repository at this point in the history
…ease-0.36

[Backport release-0.36] Update setup.go
  • Loading branch information
Christopher Haar authored Jan 18, 2023
2 parents ca0154a + 6777ea9 commit 26204db
Showing 1 changed file with 6 additions and 0 deletions.
6 changes: 6 additions & 0 deletions pkg/controller/kafka/cluster/setup.go
Original file line number Diff line number Diff line change
Expand Up @@ -39,6 +39,7 @@ func SetupCluster(mgr ctrl.Manager, o controller.Options) error {
name := managed.ControllerName(svcapitypes.ClusterGroupKind)
opts := []option{
func(e *external) {
e.preObserve = preObserve
e.postObserve = postObserve
e.preDelete = preDelete
e.postDelete = postDelete
Expand Down Expand Up @@ -83,6 +84,11 @@ func postDelete(_ context.Context, cr *svcapitypes.Cluster, obj *svcsdk.DeleteCl
return err
}

func preObserve(_ context.Context, cr *svcapitypes.Cluster, obj *svcsdk.DescribeClusterInput) error {
obj.ClusterArn = awsclients.String(meta.GetExternalName(cr))
return nil
}

func postObserve(_ context.Context, cr *svcapitypes.Cluster, obj *svcsdk.DescribeClusterOutput, obs managed.ExternalObservation, err error) (managed.ExternalObservation, error) {
if err != nil {
return managed.ExternalObservation{}, err
Expand Down

0 comments on commit 26204db

Please sign in to comment.