@@ -53,7 +53,7 @@ func (r *TelemetryControllerReconciler) Reconcile(ctx context.Context, req ctrl.
5353 log := r .Log .WithValues ("telemetry-controller" , req .Name )
5454
5555 var logging loggingv1beta1.Logging
56- if err := r .Client . Get (ctx , req .NamespacedName , & logging ); err != nil {
56+ if err := r .Get (ctx , req .NamespacedName , & logging ); err != nil {
5757 return reconcile.Result {}, client .IgnoreNotFound (err )
5858 }
5959
@@ -100,11 +100,11 @@ func (r *TelemetryControllerReconciler) createTelemetryControllerResources(logge
100100func (r * TelemetryControllerReconciler ) finalizeLoggingForTelemetryController (ctx context.Context , logger logr.Logger , logging * loggingv1beta1.Logging , objectsToCreate * []client.Object ) error {
101101 logger .Info ("Finalizing Telemetry controller resources" )
102102
103- if logging .ObjectMeta . DeletionTimestamp .IsZero () {
103+ if logging .DeletionTimestamp .IsZero () {
104104 if ! controllerutil .ContainsFinalizer (logging , TelemetryControllerFinalizer ) {
105105 r .Log .Info ("adding telemetrycontroller finalizer" )
106106 controllerutil .AddFinalizer (logging , TelemetryControllerFinalizer )
107- if err := r .Client . Update (ctx , logging ); err != nil {
107+ if err := r .Update (ctx , logging ); err != nil {
108108 return err
109109 }
110110 }
@@ -117,7 +117,7 @@ func (r *TelemetryControllerReconciler) finalizeLoggingForTelemetryController(ct
117117
118118 r .Log .Info ("removing telemetrycontroller finalizer" )
119119 controllerutil .RemoveFinalizer (logging , TelemetryControllerFinalizer )
120- if err := r .Client . Update (ctx , logging ); err != nil {
120+ if err := r .Update (ctx , logging ); err != nil {
121121 return err
122122 }
123123 }
@@ -130,11 +130,11 @@ func (r *TelemetryControllerReconciler) deployTelemetryControllerResources(ctx c
130130 logger .Info ("Deploying Telemetry controller resources" )
131131
132132 for _ , objectToCreate := range * objectsToCreate {
133- if err := r .Client . Get (ctx , client .ObjectKeyFromObject (objectToCreate ), objectToCreate ); err != nil {
133+ if err := r .Get (ctx , client .ObjectKeyFromObject (objectToCreate ), objectToCreate ); err != nil {
134134 if ! apierrors .IsNotFound (err ) {
135135 return err
136136 }
137- if err := r .Client . Create (ctx , objectToCreate ); err != nil {
137+ if err := r .Create (ctx , objectToCreate ); err != nil {
138138 return err
139139 }
140140 logger .Info ("Created object" , "object" , objectToCreate .GetName ())
@@ -150,7 +150,7 @@ func (r *TelemetryControllerReconciler) deleteTelemetryControllerResources(ctx c
150150 logger .Info ("Logging resource is being deleted, deleting Telemetry controller resources" )
151151
152152 for _ , obj := range * objectsToCreate {
153- if err := r .Client . Delete (ctx , obj ); err != nil {
153+ if err := r .Delete (ctx , obj ); err != nil {
154154 return client .IgnoreNotFound (err )
155155 }
156156 logger .Info ("Deleted object" , "object" , obj .GetName ())
@@ -164,7 +164,7 @@ func (r *TelemetryControllerReconciler) isAggregatorReady(ctx context.Context, l
164164
165165 podName := fmt .Sprintf ("%s-fluentd-0" , logging .Name )
166166 pod := & corev1.Pod {}
167- err := r .Client . Get (ctx , client.ObjectKey {Name : podName , Namespace : logging .Spec .ControlNamespace }, pod )
167+ err := r .Get (ctx , client.ObjectKey {Name : podName , Namespace : logging .Spec .ControlNamespace }, pod )
168168 if err != nil {
169169 if apierrors .IsNotFound (err ) {
170170 return fmt .Errorf ("aggregator pod: %s not found" , podName )
0 commit comments