Skip to content

Commit

Permalink
bug with external name firehose fixed
Browse files Browse the repository at this point in the history
  • Loading branch information
nilde committed Oct 17, 2023
1 parent 70d489d commit 9e4b850
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 2 deletions.
2 changes: 1 addition & 1 deletion examples/firehose/deliverystream.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ spec:
forProvider:
region: us-east-1
deliveryStreamName: firehose-deliverystream
deliveryStreamType: KinesisStreamAsSource
deliveryStreamType: DirectPut
extendedS3DestinationConfiguration:
roleARN: arn:aws:iam::000000000000:role/Firehose-Example-Role
bucketARN: arn:aws:s3:::bucket-example
Expand Down
5 changes: 4 additions & 1 deletion pkg/controller/firehose/deliverystream/setup.go
Original file line number Diff line number Diff line change
Expand Up @@ -58,6 +58,10 @@ func SetupDeliveryStream(mgr ctrl.Manager, o controller.Options) error {

reconcilerOpts := []managed.ReconcilerOption{
managed.WithExternalConnecter(&connector{kube: mgr.GetClient(), opts: opts}),
managed.WithReferenceResolver(managed.NewAPISimpleReferenceResolver(mgr.GetClient())),
managed.WithInitializers(
managed.NewDefaultProviderConfig(mgr.GetClient()),
managed.NewNameAsExternalName(mgr.GetClient())),
managed.WithPollInterval(o.PollInterval),
managed.WithLogger(o.Logger.WithValues("controller", name)),
managed.WithRecorder(event.NewAPIRecorder(mgr.GetEventRecorderFor(name))),
Expand Down Expand Up @@ -121,6 +125,5 @@ func postCreate(_ context.Context, cr *svcapitypes.DeliveryStream, obj *svcsdk.C
if err != nil {
return managed.ExternalCreation{}, err
}
meta.SetExternalName(cr, cr.Name)
return managed.ExternalCreation{ExternalNameAssigned: true}, nil
}

0 comments on commit 9e4b850

Please sign in to comment.