From e0785d6713355c51e5d74ef688776f1db1447038 Mon Sep 17 00:00:00 2001 From: austin ce Date: Fri, 2 Dec 2022 14:06:37 -0500 Subject: [PATCH] Remove options from queue ctors w/o metrics Kubernetes-commit: 31f16db1959bb1db02fcc578f4aa7d47414a26f4 --- util/workqueue/delaying_queue.go | 4 ++-- util/workqueue/rate_limiting_queue.go | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/util/workqueue/delaying_queue.go b/util/workqueue/delaying_queue.go index 1fd9ad5c..1ace7671 100644 --- a/util/workqueue/delaying_queue.go +++ b/util/workqueue/delaying_queue.go @@ -36,8 +36,8 @@ type DelayingInterface interface { // NewDelayingQueue constructs a new workqueue with delayed queuing ability. // NewDelayingQueue does not emit metrics. For use with a MetricsProvider, please use // NewNamedDelayingQueue instead. -func NewDelayingQueue(opts ...QueueOption) DelayingInterface { - return NewDelayingQueueWithCustomClock(clock.RealClock{}, "", opts...) +func NewDelayingQueue() DelayingInterface { + return NewDelayingQueueWithCustomClock(clock.RealClock{}, "") } // NewDelayingQueueWithCustomQueue constructs a new workqueue with ability to diff --git a/util/workqueue/rate_limiting_queue.go b/util/workqueue/rate_limiting_queue.go index 39fddc0a..6b07b4a3 100644 --- a/util/workqueue/rate_limiting_queue.go +++ b/util/workqueue/rate_limiting_queue.go @@ -36,9 +36,9 @@ type RateLimitingInterface interface { // 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 // NewNamedRateLimitingQueue instead. -func NewRateLimitingQueue(rateLimiter RateLimiter, opts ...QueueOption) RateLimitingInterface { +func NewRateLimitingQueue(rateLimiter RateLimiter) RateLimitingInterface { return &rateLimitingType{ - DelayingInterface: NewDelayingQueue(opts...), + DelayingInterface: NewDelayingQueue(), rateLimiter: rateLimiter, } }