github/client-go
1
0
Fork 0
mirror of https://github.com/kubernetes/client-go.git synced 2025-09-06 01:20:40 +00:00
Code Issues Projects Releases Wiki Activity

Remove options from queue ctors w/o metrics

Browse Source 
Kubernetes-commit: 31f16db1959bb1db02fcc578f4aa7d47414a26f4
This commit is contained in:
austin ce
2022-12-02 14:06:37 -05:00
committed by Kubernetes Publisher
parent 89a4c1271f
commit e0785d6713
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
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
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,
} }
} }