- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for NewRateLimitingQueue (0.33 sec)
-
pkg/kube/controllers/queue.go
q.name = name } } // WithRateLimiter allows defining a custom rate limiter for the queue func WithRateLimiter(r workqueue.RateLimiter) func(q *Queue) { return func(q *Queue) { q.queue = workqueue.NewRateLimitingQueue(r) } } // WithMaxAttempts allows defining a custom max attempts for the queue. If not set, items will not be retried func WithMaxAttempts(n int) func(q *Queue) { return func(q *Queue) { q.maxAttempts = n
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 08 16:43:05 UTC 2023 - 6.3K bytes - Viewed (0)