@@ -77,7 +77,7 @@ func (r *AutoscalingListenerReconciler) Reconcile(ctx context.Context, req ctrl.
77
77
return ctrl.Result {}, client .IgnoreNotFound (err )
78
78
}
79
79
80
- if ! autoscalingListener .ObjectMeta . DeletionTimestamp .IsZero () {
80
+ if ! autoscalingListener .DeletionTimestamp .IsZero () {
81
81
if ! controllerutil .ContainsFinalizer (autoscalingListener , autoscalingListenerFinalizerName ) {
82
82
return ctrl.Result {}, nil
83
83
}
@@ -281,7 +281,7 @@ func (r *AutoscalingListenerReconciler) cleanupResources(ctx context.Context, au
281
281
err = r .Get (ctx , types.NamespacedName {Name : autoscalingListener .Name , Namespace : autoscalingListener .Namespace }, listenerPod )
282
282
switch {
283
283
case err == nil :
284
- if listenerPod .ObjectMeta . DeletionTimestamp .IsZero () {
284
+ if listenerPod .DeletionTimestamp .IsZero () {
285
285
logger .Info ("Deleting the listener pod" )
286
286
if err := r .Delete (ctx , listenerPod ); err != nil {
287
287
return false , fmt .Errorf ("failed to delete listener pod: %w" , err )
@@ -299,7 +299,7 @@ func (r *AutoscalingListenerReconciler) cleanupResources(ctx context.Context, au
299
299
err = r .Get (ctx , types.NamespacedName {Namespace : autoscalingListener .Namespace , Name : scaleSetListenerConfigName (autoscalingListener )}, & secret )
300
300
switch {
301
301
case err == nil :
302
- if secret .ObjectMeta . DeletionTimestamp .IsZero () {
302
+ if secret .DeletionTimestamp .IsZero () {
303
303
logger .Info ("Deleting the listener config secret" )
304
304
if err := r .Delete (ctx , & secret ); err != nil {
305
305
return false , fmt .Errorf ("failed to delete listener config secret: %w" , err )
@@ -316,7 +316,7 @@ func (r *AutoscalingListenerReconciler) cleanupResources(ctx context.Context, au
316
316
err = r .Get (ctx , types.NamespacedName {Name : proxyListenerSecretName (autoscalingListener ), Namespace : autoscalingListener .Namespace }, proxySecret )
317
317
switch {
318
318
case err == nil :
319
- if proxySecret .ObjectMeta . DeletionTimestamp .IsZero () {
319
+ if proxySecret .DeletionTimestamp .IsZero () {
320
320
logger .Info ("Deleting the listener proxy secret" )
321
321
if err := r .Delete (ctx , proxySecret ); err != nil {
322
322
return false , fmt .Errorf ("failed to delete listener proxy secret: %w" , err )
@@ -333,7 +333,7 @@ func (r *AutoscalingListenerReconciler) cleanupResources(ctx context.Context, au
333
333
err = r .Get (ctx , types.NamespacedName {Namespace : autoscalingListener .Spec .AutoscalingRunnerSetNamespace , Name : scaleSetListenerRoleName (autoscalingListener )}, listenerRoleBinding )
334
334
switch {
335
335
case err == nil :
336
- if listenerRoleBinding .ObjectMeta . DeletionTimestamp .IsZero () {
336
+ if listenerRoleBinding .DeletionTimestamp .IsZero () {
337
337
logger .Info ("Deleting the listener role binding" )
338
338
if err := r .Delete (ctx , listenerRoleBinding ); err != nil {
339
339
return false , fmt .Errorf ("failed to delete listener role binding: %w" , err )
@@ -349,7 +349,7 @@ func (r *AutoscalingListenerReconciler) cleanupResources(ctx context.Context, au
349
349
err = r .Get (ctx , types.NamespacedName {Namespace : autoscalingListener .Spec .AutoscalingRunnerSetNamespace , Name : scaleSetListenerRoleName (autoscalingListener )}, listenerRole )
350
350
switch {
351
351
case err == nil :
352
- if listenerRole .ObjectMeta . DeletionTimestamp .IsZero () {
352
+ if listenerRole .DeletionTimestamp .IsZero () {
353
353
logger .Info ("Deleting the listener role" )
354
354
if err := r .Delete (ctx , listenerRole ); err != nil {
355
355
return false , fmt .Errorf ("failed to delete listener role: %w" , err )
@@ -366,7 +366,7 @@ func (r *AutoscalingListenerReconciler) cleanupResources(ctx context.Context, au
366
366
err = r .Get (ctx , types.NamespacedName {Name : scaleSetListenerServiceAccountName (autoscalingListener ), Namespace : autoscalingListener .Namespace }, listenerSa )
367
367
switch {
368
368
case err == nil :
369
- if listenerSa .ObjectMeta . DeletionTimestamp .IsZero () {
369
+ if listenerSa .DeletionTimestamp .IsZero () {
370
370
logger .Info ("Deleting the listener service account" )
371
371
if err := r .Delete (ctx , listenerSa ); err != nil {
372
372
return false , fmt .Errorf ("failed to delete listener service account: %w" , err )
@@ -382,7 +382,7 @@ func (r *AutoscalingListenerReconciler) cleanupResources(ctx context.Context, au
382
382
}
383
383
384
384
func (r * AutoscalingListenerReconciler ) createServiceAccountForListener (ctx context.Context , autoscalingListener * v1alpha1.AutoscalingListener , logger logr.Logger ) (ctrl.Result , error ) {
385
- newServiceAccount := r .ResourceBuilder . newScaleSetListenerServiceAccount (autoscalingListener )
385
+ newServiceAccount := r .newScaleSetListenerServiceAccount (autoscalingListener )
386
386
387
387
if err := ctrl .SetControllerReference (autoscalingListener , newServiceAccount , r .Scheme ); err != nil {
388
388
return ctrl.Result {}, err
@@ -467,7 +467,7 @@ func (r *AutoscalingListenerReconciler) createListenerPod(ctx context.Context, a
467
467
468
468
logger .Info ("Creating listener config secret" )
469
469
470
- podConfig , err := r .ResourceBuilder . newScaleSetListenerConfig (autoscalingListener , secret , metricsConfig , cert )
470
+ podConfig , err := r .newScaleSetListenerConfig (autoscalingListener , secret , metricsConfig , cert )
471
471
if err != nil {
472
472
logger .Error (err , "Failed to build listener config secret" )
473
473
return ctrl.Result {}, err
@@ -486,7 +486,7 @@ func (r *AutoscalingListenerReconciler) createListenerPod(ctx context.Context, a
486
486
return ctrl.Result {Requeue : true }, nil
487
487
}
488
488
489
- newPod , err := r .ResourceBuilder . newScaleSetListenerPod (autoscalingListener , & podConfig , serviceAccount , secret , metricsConfig , envs ... )
489
+ newPod , err := r .newScaleSetListenerPod (autoscalingListener , & podConfig , serviceAccount , secret , metricsConfig , envs ... )
490
490
if err != nil {
491
491
logger .Error (err , "Failed to build listener pod" )
492
492
return ctrl.Result {}, err
@@ -546,7 +546,7 @@ func (r *AutoscalingListenerReconciler) certificate(ctx context.Context, autosca
546
546
}
547
547
548
548
func (r * AutoscalingListenerReconciler ) createSecretsForListener (ctx context.Context , autoscalingListener * v1alpha1.AutoscalingListener , secret * corev1.Secret , logger logr.Logger ) (ctrl.Result , error ) {
549
- newListenerSecret := r .ResourceBuilder . newScaleSetListenerSecretMirror (autoscalingListener , secret )
549
+ newListenerSecret := r .newScaleSetListenerSecretMirror (autoscalingListener , secret )
550
550
551
551
if err := ctrl .SetControllerReference (autoscalingListener , newListenerSecret , r .Scheme ); err != nil {
552
552
return ctrl.Result {}, err
@@ -618,7 +618,7 @@ func (r *AutoscalingListenerReconciler) updateSecretsForListener(ctx context.Con
618
618
}
619
619
620
620
func (r * AutoscalingListenerReconciler ) createRoleForListener (ctx context.Context , autoscalingListener * v1alpha1.AutoscalingListener , logger logr.Logger ) (ctrl.Result , error ) {
621
- newRole := r .ResourceBuilder . newScaleSetListenerRole (autoscalingListener )
621
+ newRole := r .newScaleSetListenerRole (autoscalingListener )
622
622
623
623
logger .Info ("Creating listener role" , "namespace" , newRole .Namespace , "name" , newRole .Name , "rules" , newRole .Rules )
624
624
if err := r .Create (ctx , newRole ); err != nil {
@@ -646,7 +646,7 @@ func (r *AutoscalingListenerReconciler) updateRoleForListener(ctx context.Contex
646
646
}
647
647
648
648
func (r * AutoscalingListenerReconciler ) createRoleBindingForListener (ctx context.Context , autoscalingListener * v1alpha1.AutoscalingListener , listenerRole * rbacv1.Role , serviceAccount * corev1.ServiceAccount , logger logr.Logger ) (ctrl.Result , error ) {
649
- newRoleBinding := r .ResourceBuilder . newScaleSetListenerRoleBinding (autoscalingListener , listenerRole , serviceAccount )
649
+ newRoleBinding := r .newScaleSetListenerRoleBinding (autoscalingListener , listenerRole , serviceAccount )
650
650
651
651
logger .Info ("Creating listener role binding" ,
652
652
"namespace" , newRoleBinding .Namespace ,
0 commit comments