NewRateLimitingQueue constructs a new workqueue with rateLimited queuing ability Remember to call Forget! If you don't, you may end up tracking failures forever.
(rateLimiter RateLimiter)
| 35 | // NewRateLimitingQueue constructs a new workqueue with rateLimited queuing ability |
| 36 | // Remember to call Forget! If you don't, you may end up tracking failures forever. |
| 37 | func NewRateLimitingQueue(rateLimiter RateLimiter) RateLimitingInterface { |
| 38 | return &rateLimitingType{ |
| 39 | DelayingInterface: NewDelayingQueue(), |
| 40 | rateLimiter: rateLimiter, |
| 41 | } |
| 42 | } |
| 43 | |
| 44 | func NewNamedRateLimitingQueue(rateLimiter RateLimiter, name string) RateLimitingInterface { |
| 45 | return &rateLimitingType{ |