Skip to content

Commit 45d4532

Browse files
committed
feat: fix panic
1 parent aef9fef commit 45d4532

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

controller/controller.go

+4-4
Original file line numberDiff line numberDiff line change
@@ -421,7 +421,7 @@ func (c *ObjectStorageController) runController(ctx context.Context) {
421421
if c.BucketListener != nil {
422422
c.BucketListener.InitializeKubeClient(c.kubeClient)
423423
c.BucketListener.InitializeBucketClient(c.bucketClient)
424-
c.BucketAccessListener.InitializeEventRecorder(c.eventRecorder)
424+
c.BucketListener.InitializeEventRecorder(c.eventRecorder)
425425
addFunc := func(ctx context.Context, obj interface{}) error {
426426
return c.BucketListener.Add(ctx, obj.(*v1alpha1.Bucket))
427427
}
@@ -436,7 +436,7 @@ func (c *ObjectStorageController) runController(ctx context.Context) {
436436
if c.BucketClaimListener != nil {
437437
c.BucketClaimListener.InitializeKubeClient(c.kubeClient)
438438
c.BucketClaimListener.InitializeBucketClient(c.bucketClient)
439-
c.BucketAccessListener.InitializeEventRecorder(c.eventRecorder)
439+
c.BucketClaimListener.InitializeEventRecorder(c.eventRecorder)
440440
addFunc := func(ctx context.Context, obj interface{}) error {
441441
return c.BucketClaimListener.Add(ctx, obj.(*v1alpha1.BucketClaim))
442442
}
@@ -466,7 +466,7 @@ func (c *ObjectStorageController) runController(ctx context.Context) {
466466
if c.BucketClassListener != nil {
467467
c.BucketClassListener.InitializeKubeClient(c.kubeClient)
468468
c.BucketClassListener.InitializeBucketClient(c.bucketClient)
469-
c.BucketAccessListener.InitializeEventRecorder(c.eventRecorder)
469+
c.BucketClassListener.InitializeEventRecorder(c.eventRecorder)
470470
addFunc := func(ctx context.Context, obj interface{}) error {
471471
return c.BucketClassListener.Add(ctx, obj.(*v1alpha1.BucketClass))
472472
}
@@ -481,7 +481,7 @@ func (c *ObjectStorageController) runController(ctx context.Context) {
481481
if c.BucketAccessClassListener != nil {
482482
c.BucketAccessClassListener.InitializeKubeClient(c.kubeClient)
483483
c.BucketAccessClassListener.InitializeBucketClient(c.bucketClient)
484-
c.BucketAccessListener.InitializeEventRecorder(c.eventRecorder)
484+
c.BucketAccessClassListener.InitializeEventRecorder(c.eventRecorder)
485485
addFunc := func(ctx context.Context, obj interface{}) error {
486486
return c.BucketAccessClassListener.Add(ctx, obj.(*v1alpha1.BucketAccessClass))
487487
}

0 commit comments

Comments
 (0)