From 3dfaef50d72cb920ec467e3593b7381b74b9d96b Mon Sep 17 00:00:00 2001
From: Aldo Culquicondor <acondor@google.com>
Date: Tue, 26 Jul 2022 15:11:53 -0400
Subject: [PATCH] Add clock interface to disruption controller

To be able to write more precise unit tests in the future

Change-Id: I8f45947dfacca501acd856849bd978fad0f735cd

Kubernetes-commit: dad8454ebb87ba7af897537db6d34033127bbfef
---
 util/workqueue/rate_limiting_queue.go | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/util/workqueue/rate_limiting_queue.go b/util/workqueue/rate_limiting_queue.go
index 267f4ff4..91cd33f1 100644
--- a/util/workqueue/rate_limiting_queue.go
+++ b/util/workqueue/rate_limiting_queue.go
@@ -50,6 +50,13 @@ func NewNamedRateLimitingQueue(rateLimiter RateLimiter, name string) RateLimitin
 	}
 }
 
+func NewRateLimitingQueueWithDelayingInterface(di DelayingInterface, rateLimiter RateLimiter) RateLimitingInterface {
+	return &rateLimitingType{
+		DelayingInterface: di,
+		rateLimiter:       rateLimiter,
+	}
+}
+
 // rateLimitingType wraps an Interface and provides rateLimited re-enquing
 type rateLimitingType struct {
 	DelayingInterface