Versions in this module Expand all Collapse all v1 v1.9.2 Apr 2, 2023 Changes in this version + const MaxRetries + func DefaultRetryFunc(ctx context.Context, key string, timesTried int, originallyAdded time.Time, ...) (*time.Duration, error) + type ItemHandler func(ctx context.Context, key string) error + type Queue struct + func New(ratelimiter workqueue.RateLimiter, name string, handler ItemHandler, ...) *Queue + func (q *Queue) Empty() bool + func (q *Queue) Enqueue(ctx context.Context, key string) + func (q *Queue) EnqueueWithoutRateLimit(ctx context.Context, key string) + func (q *Queue) EnqueueWithoutRateLimitWithDelay(ctx context.Context, key string, after time.Duration) + func (q *Queue) Forget(ctx context.Context, key string) + func (q *Queue) Len() int + func (q *Queue) Run(ctx context.Context, workers int) + func (q *Queue) String() string + type ShouldRetryFunc func(ctx context.Context, key string, timesTried int, originallyAdded time.Time, ...) (*time.Duration, error)
Go to main page