@@ -25,7 +25,6 @@ import (
2525 "strings"
2626 "time"
2727
28- "github.com/go-logr/logr"
2928 "github.com/minio/minio-go/v7"
3029 "github.com/minio/minio-go/v7/pkg/credentials"
3130 "github.com/minio/minio-go/v7/pkg/s3utils"
@@ -268,7 +267,7 @@ func (r *BucketReconciler) reconcileDelete(ctx context.Context, bucket sourcev1.
268267// reconcileWithGCP handles getting objects from a Google Cloud Platform bucket
269268// using a gcp client
270269func (r * BucketReconciler ) reconcileWithGCP (ctx context.Context , bucket sourcev1.Bucket , tempDir string ) (sourcev1.Bucket , error ) {
271- log := logr . FromContext (ctx )
270+ log := ctrl . LoggerFrom (ctx )
272271 gcpClient , err := r .authGCP (ctx , bucket )
273272 if err != nil {
274273 err = fmt .Errorf ("auth error: %w" , err )
@@ -534,7 +533,7 @@ func (r *BucketReconciler) gc(bucket sourcev1.Bucket) error {
534533
535534// event emits a Kubernetes event and forwards the event to notification controller if configured
536535func (r * BucketReconciler ) event (ctx context.Context , bucket sourcev1.Bucket , severity , msg string ) {
537- log := logr . FromContext (ctx )
536+ log := ctrl . LoggerFrom (ctx )
538537 if r .EventRecorder != nil {
539538 r .EventRecorder .Eventf (& bucket , "Normal" , severity , msg )
540539 }
@@ -553,7 +552,7 @@ func (r *BucketReconciler) event(ctx context.Context, bucket sourcev1.Bucket, se
553552}
554553
555554func (r * BucketReconciler ) recordReadiness (ctx context.Context , bucket sourcev1.Bucket ) {
556- log := logr . FromContext (ctx )
555+ log := ctrl . LoggerFrom (ctx )
557556 if r .MetricsRecorder == nil {
558557 return
559558 }
@@ -576,7 +575,7 @@ func (r *BucketReconciler) recordSuspension(ctx context.Context, bucket sourcev1
576575 if r .MetricsRecorder == nil {
577576 return
578577 }
579- log := logr . FromContext (ctx )
578+ log := ctrl . LoggerFrom (ctx )
580579
581580 objRef , err := reference .GetReference (r .Scheme , & bucket )
582581 if err != nil {
0 commit comments