taskqueue

Jan 25, 2026

Changes in this version

+ type Payload []byte

+ type Task struct

+ ID string

+ Payload Payload

Jan 21, 2026

Changes in this version

+ var ErrEmptyQueueKey = errors.New("taskqueue: queue key is empty")

+ var ErrMaxAgeTooSmall = errors.New("taskqueue: maxAge must be greater than execTimeout")

+ var ErrNilClient = errors.New("taskqueue: redis client is nil")

+ var ErrNilExecutor = errors.New("taskqueue: task executor is nil")

+ var ErrQueueAlreadyRunning = errors.New("taskqueue: queue is already running")

+ var ErrQueueNotRunning = errors.New("taskqueue: queue is not running")

+ type Executor interface

+ Execute func(ctx context.Context, taskID string) error

+ type Option func(*Queue)

+ func WithBufferSize(size int) Option

+ func WithExecTimeout(timeout time.Duration) Option

+ func WithPollInterval(interval time.Duration) Option

+ func WithWorkerCount(count int) Option

+ type Queue struct

+ func New(client redis.UniversalClient, queueKey string, executor Executor, ...) (*Queue, error)

+ func (q *Queue) Name() string

+ func (q *Queue) ProcessingCount(ctx context.Context) (int64, error)

+ func (q *Queue) Push(ctx context.Context, taskIDs ...string) error

+ func (q *Queue) QueueLength(ctx context.Context) (int64, error)

+ func (q *Queue) RecoverStale(ctx context.Context, maxAge time.Duration) (int, error)

+ func (q *Queue) Start(ctx context.Context) error

+ func (q *Queue) Stop() error