@@ -2,15 +2,16 @@ package controllers
2
2
3
3
import (
4
4
"context"
5
+ "math/rand"
6
+ "time"
7
+
5
8
"github.com/go-logr/logr"
6
9
"k8s.io/apimachinery/pkg/types"
7
10
"k8s.io/client-go/util/workqueue"
8
- "math/rand"
9
11
elbv2api "sigs.k8s.io/aws-load-balancer-controller/apis/elbv2/v1beta1"
10
12
"sigs.k8s.io/aws-load-balancer-controller/pkg/k8s"
11
13
"sigs.k8s.io/aws-load-balancer-controller/pkg/targetgroupbinding"
12
14
"sigs.k8s.io/controller-runtime/pkg/client"
13
- "time"
14
15
)
15
16
16
17
const (
@@ -56,7 +57,7 @@ func (d *deferredTargetGroupBindingReconcilerImpl) Enqueue(tgb *elbv2api.TargetG
56
57
nsn := k8s .NamespacedName (tgb )
57
58
if d .isEligibleForDefer (tgb ) {
58
59
d .enqueue (nsn )
59
- d .logger .Info ("enqueued new deferred TGB" , "TGB " , nsn .Name )
60
+ d .logger .Info ("enqueued new deferred TGB" , "tgb " , nsn .Name )
60
61
}
61
62
}
62
63
@@ -88,7 +89,7 @@ func (d *deferredTargetGroupBindingReconcilerImpl) handleDeferredItem(nsn types.
88
89
89
90
// Re-check that this tgb hasn't been updated since it was enqueued
90
91
if ! d .isEligibleForDefer (tgb ) {
91
- d .logger .Info ("TGB not eligible for deferral" , "TGB " , nsn )
92
+ d .logger .Info ("TGB not eligible for deferral" , "tgb " , nsn )
92
93
return
93
94
}
94
95
@@ -99,13 +100,13 @@ func (d *deferredTargetGroupBindingReconcilerImpl) handleDeferredItem(nsn types.
99
100
d .handleDeferredItemError (nsn , err , "Failed to reset TGB checkpoint" )
100
101
return
101
102
}
102
- d .logger .Info ("TGB checkpoint reset" , "TGB " , nsn )
103
+ d .logger .Info ("TGB checkpoint reset" , "tgb " , nsn )
103
104
}
104
105
105
106
func (d * deferredTargetGroupBindingReconcilerImpl ) handleDeferredItemError (nsn types.NamespacedName , err error , msg string ) {
106
107
err = client .IgnoreNotFound (err )
107
108
if err != nil {
108
- d .logger .Error (err , msg , "TGB " , nsn )
109
+ d .logger .Error (err , msg , "tgb " , nsn )
109
110
d .enqueue (nsn )
110
111
}
111
112
}
0 commit comments