Versions in this module Expand all Collapse all v0 v0.0.3 Jan 29, 2023 v0.0.2 Jan 29, 2023 Changes in this version + func NewQueue(pool Pool, opts ...Option) TaskQueue + func NewTask(namespace string) *task + func NewTaskWithPriority(namespace string, priority int) *task + func NewTaskWithPriorityAndExpiresAt(namespace string, priority int, expires_at time.Time) *task + type Option func(*queue) error + func OptBackoff(v time.Duration) Option + func OptMaxAge(v time.Duration) Option + func OptMaxRetries(v uint) Option + func OptNamespace(v string) Option + func OptWorkers(n uint, deadline time.Duration) Option
Go to main page