Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for NewRateLimitingQueue (0.22 sec)

  1. 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)
Back to top