Versions in this module Expand all Collapse all v1 v1.5.1 Apr 28, 2017 Changes in this version + func RetryAlways(obj interface{}, err error, retries Retry) bool + func RetryNever(obj interface{}, err error, retries Retry) bool + type Queue interface + Pop func(kcache.PopProcessFunc) (interface{}, error) + type QueueRetryManager struct + func NewQueueRetryManager(queue ReQueue, keyFn kcache.KeyFunc, retryFn RetryFunc, ...) *QueueRetryManager + func (r *QueueRetryManager) Forget(resource interface{}) + func (r *QueueRetryManager) Retry(resource interface{}, err error) + type ReQueue interface + AddIfNotPresent func(interface{}) error + type Retry struct + Count int + StartTimestamp unversioned.Time + type RetryController struct + Handle func(interface{}) error + func (c *RetryController) Run() + func (c *RetryController) RunUntil(stopCh <-chan struct{}) + type RetryFunc func(obj interface{}, err error, retries Retry) bool + type RetryManager interface + Forget func(resource interface{}) + Retry func(resource interface{}, err error) + type RunnableController interface + Run func() + type Scheduler struct + func NewScheduler(bucketCount int, bucketLimiter flowcontrol.RateLimiter, ...) *Scheduler + func (s *Scheduler) Add(key, value interface{}) + func (s *Scheduler) Delay(key interface{}) + func (s *Scheduler) Len() int + func (s *Scheduler) Map() map[interface{}]interface{} + func (s *Scheduler) Remove(key, value interface{}) bool + func (s *Scheduler) RunOnce() + func (s *Scheduler) RunUntil(ch <-chan struct{}) + type StoppableController interface + RunUntil func(ch <-chan struct{}) v1.5.0-alpha.1 Dec 29, 2016 Incompatible versions in this module v3.7.0-alpha.0+incompatible Aug 1, 2017
Go to main page