RatelimitingInterface have a new method ShutdownWithDrain

The workqueue ratelimiting interface have a new method called ShutDownWithDrain() and this commit adds an unimplemented method in capacity_test.go for using the rateLimitingQueue as type workqueue.RateLimitingInterface. Signed-off-by: Humble Chirammal <[email protected]>
kubernetes-csi · Dec 14, 2021 · 2723a28 · 2723a28
1 parent 9f2e818
commit 2723a28
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/pkg/capacity/capacity_test.go b/pkg/capacity/capacity_test.go
@@ -1381,6 +1381,10 @@ type rateLimitingQueue struct {
 	shuttingDown bool
 }
 
+func (r *rateLimitingQueue) ShutDownWithDrain() {
+	klog.Error("ShutDownWithDrain is unimplemented")
+}
+
 var _ workqueue.RateLimitingInterface = &rateLimitingQueue{}
 
 func (r *rateLimitingQueue) Add(item interface{}) {