queue

Jul 29, 2024

Changes in this version

+ const MaxRetries

+ func DefaultRetryFunc(_ context.Context, _ string, timesTried int, _ time.Time, err error) (*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) ItemsBeingProcessedLen() int

+ func (q *Queue) Len() int

+ func (q *Queue) Run(ctx context.Context, workers int)

+ func (q *Queue) String() string

+ func (q *Queue) UnprocessedLen() int

+ type ShouldRetryFunc func(ctx context.Context, key string, timesTried int, originallyAdded time.Time, ...) (*time.Duration, error)