worker

Mar 24, 2026

Changes in this version

type Enqueuer

+ EnqueueTask func(t *Task) error

Mar 16, 2026

Changes in this version

type EnqueuerOpts

+ RedisDB int

type WorkerOpts

+ RedisDB int

Aug 26, 2023

Changes in this version

type Worker

+ Stop func()

Aug 26, 2023

Changes in this version

type Handler

+ TaskName string

Aug 26, 2023

Changes in this version

+ func SetupUI(router *nrhttprouter.Router, opts *UIOpts)

+ type Enqueuer interface

+ EnqueueUniqueTask func(*Task) error

+ EnqueueUniqueTaskIn func(*Task, time.Duration) error

+ func NewEnqueuer(opts *EnqueuerOpts) Enqueuer

+ type EnqueuerOpts struct

+ PoolSize int

+ RedisUrl string

+ type Handler struct

+ HandlerFunc asynq.HandlerFunc

+ Name string

+ type Middleware interface

+ ProcessTask func(context.Context, *Task) error

+ type Queue struct

+ Name string

+ Priority int

+ type Task struct

+ Name string

+ Payload interface{}

+ Retry int

+ Timeout time.Duration

+ type UIOpts struct

+ Endpoint string

+ Password string

+ RedisUrl string

+ Username string

+ type Worker interface

+ RegisterHandlers func([]*Handler)

+ Start func(context.Context) error

+ func NewWorker(opts *WorkerOpts) (Worker, error)

+ type WorkerOpts struct

+ Concurrency int

+ PoolSize int

+ Queues []*Queue

+ RedisUrl string

+ ShutdownTimeout time.Duration