Versions in this module Expand all Collapse all v0 v0.3.3 Feb 27, 2015 Changes in this version + type Queue interface + AddIfNotPresent func(interface{}) error + Pop func() interface{} + type QueueRetryManager struct + func NewQueueRetryManager(queue Queue, keyFunc kcache.KeyFunc, maxRetries int) *QueueRetryManager + func (r *QueueRetryManager) Forget(resource interface{}) + func (r *QueueRetryManager) Retry(resource interface{}) + type RetryController struct + Handle func(interface{}) error + Queue Queue + RetryManager RetryManager + ShouldRetry func(interface{}, error) bool + func (c *RetryController) Run() + type RetryManager interface + Forget func(resource interface{}) + Retry func(resource interface{}) + type RunnableController interface + Run func()
Go to main page