Fix priorityqueue defaulting

alvaroaleman · alvaroaleman · commit 5905190d706c · 2024-12-06T12:55:01.000-05:00
diff --git a/pkg/controller/controller.go b/pkg/controller/controller.go
@@ -190,7 +190,11 @@ func NewTypedUnmanaged[request comparable](name string, mgr manager.Manager, opt
 	}
 
 	if options.RateLimiter == nil {
-		options.RateLimiter = workqueue.DefaultTypedControllerRateLimiter[request]()
+		if mgr.GetControllerOptions().UsePriorityQueue {
+			options.RateLimiter = workqueue.NewTypedItemExponentialFailureRateLimiter[request](5*time.Millisecond, 1000*time.Second)
+		} else {
+			options.RateLimiter = workqueue.DefaultTypedControllerRateLimiter[request]()
+		}
 	}
 
 	if options.NewQueue == nil {

Original file line number	Diff line number	Diff line change
`@@ -190,7 +190,11 @@ func NewTypedUnmanaged[request comparable](name string, mgr manager.Manager, opt`
`190`	`190`	`}`
`191`	`191`
`192`	`192`	`if options.RateLimiter == nil {`
`193`		`- options.RateLimiter = workqueue.DefaultTypedControllerRateLimiter[request]()`
	`193`	`+ if mgr.GetControllerOptions().UsePriorityQueue {`
	`194`	`+ options.RateLimiter = workqueue.NewTypedItemExponentialFailureRateLimiter[request](5time.Millisecond, 1000time.Second)`
	`195`	`+ } else {`
	`196`	`+ options.RateLimiter = workqueue.DefaultTypedControllerRateLimiter[request]()`
	`197`	`+ }`
`194`	`198`	`}`
`195`	`199`
`196`	`200`	`if options.NewQueue == nil {`