@@ -57,7 +57,7 @@ func NewDynamicRateLimiter[T comparable](informerManager genericmanager.SingleCl
57
57
58
58
// When determines how long to wait before processing an item.
59
59
// Returns a longer delay when the system is unhealthy.
60
- func (d * DynamicRateLimiter [T ]) When (item T ) time.Duration {
60
+ func (d * DynamicRateLimiter [T ]) When (_ T ) time.Duration {
61
61
currentRate := d .getCurrentRate ()
62
62
if currentRate == 0 {
63
63
return maxEvictionDelay
@@ -122,12 +122,12 @@ func (d *DynamicRateLimiter[T]) getCurrentRate() float32 {
122
122
}
123
123
124
124
// Forget is a no-op as this rate limiter doesn't track individual items.
125
- func (d * DynamicRateLimiter [T ]) Forget (item T ) {
125
+ func (d * DynamicRateLimiter [T ]) Forget (_ T ) {
126
126
// No-op
127
127
}
128
128
129
129
// NumRequeues always returns 0 as this rate limiter doesn't track retries.
130
- func (d * DynamicRateLimiter [T ]) NumRequeues (item T ) int {
130
+ func (d * DynamicRateLimiter [T ]) NumRequeues (_ T ) int {
131
131
return 0
132
132
}
133
133
@@ -138,7 +138,6 @@ func NewGracefulEvictionRateLimiter[T comparable](
138
138
informerManager genericmanager.SingleClusterInformerManager ,
139
139
evictionOpts config.EvictionQueueOptions ,
140
140
rateLimiterOpts ratelimiterflag.Options ) workqueue.TypedRateLimiter [T ] {
141
-
142
141
dynamicLimiter := NewDynamicRateLimiter [T ](informerManager , evictionOpts )
143
142
defaultLimiter := ratelimiterflag.DefaultControllerRateLimiter [T ](rateLimiterOpts )
144
143
return workqueue .NewTypedMaxOfRateLimiter [T ](dynamicLimiter , defaultLimiter )
0 commit comments