github/kubernetes
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Remove options from queue ctors w/o metrics

Browse Source
This commit is contained in:
austin ce 2022-12-02 14:06:37 -05:00
parent 95ad089ff8
commit 31f16db195
No known key found for this signature in database
GPG Key ID: BACD4A6A54EBE93C
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
staging/src/k8s.io/client-go/util/workqueue/delaying_queue.go
View File

@ -36,8 +36,8 @@ type DelayingInterface interface {
// NewDelayingQueue constructs a new workqueue with delayed queuing ability. // NewDelayingQueue constructs a new workqueue with delayed queuing ability.
// NewDelayingQueue does not emit metrics. For use with a MetricsProvider, please use // NewDelayingQueue does not emit metrics. For use with a MetricsProvider, please use
// NewNamedDelayingQueue instead. // NewNamedDelayingQueue instead.
func NewDelayingQueue(opts ...QueueOption) DelayingInterface { func NewDelayingQueue() DelayingInterface {
return NewDelayingQueueWithCustomClock(clock.RealClock{}, "", opts...) return NewDelayingQueueWithCustomClock(clock.RealClock{}, "")
} }
// NewDelayingQueueWithCustomQueue constructs a new workqueue with ability to // NewDelayingQueueWithCustomQueue constructs a new workqueue with ability to

4
staging/src/k8s.io/client-go/util/workqueue/rate_limiting_queue.go
View File

@ -36,9 +36,9 @@ type RateLimitingInterface interface {
// Remember to call Forget! If you don't, you may end up tracking failures forever. // Remember to call Forget! If you don't, you may end up tracking failures forever.
// NewRateLimitingQueue does not emit metrics. For use with a MetricsProvider, please use // NewRateLimitingQueue does not emit metrics. For use with a MetricsProvider, please use
// NewNamedRateLimitingQueue instead. // NewNamedRateLimitingQueue instead.
func NewRateLimitingQueue(rateLimiter RateLimiter, opts ...QueueOption) RateLimitingInterface { func NewRateLimitingQueue(rateLimiter RateLimiter) RateLimitingInterface {
return &rateLimitingType{ return &rateLimitingType{
DelayingInterface: NewDelayingQueue(opts...), DelayingInterface: NewDelayingQueue(),
rateLimiter: rateLimiter, rateLimiter: rateLimiter,
} }
} }