- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for DefaultControllerRateLimiter (0.53 sec)
-
pkg/kube/controllers/queue.go
closed: make(chan struct{}), initialSync: atomic.NewBool(false), } for _, o := range options { o(&q) } if q.queue == nil { q.queue = workqueue.NewRateLimitingQueue(workqueue.DefaultControllerRateLimiter()) } q.log = log.WithLabels("controller", q.name) return q } // Add an item to the queue. func (q Queue) Add(item any) { q.queue.Add(item) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 08 16:43:05 UTC 2023 - 6.3K bytes - Viewed (0)