Versions in this module Expand all Collapse all v0 v0.4.0 Jul 28, 2026 Changes in this version + func Dispatch[T any](ctx context.Context, q *Queue, name string, payload T, opts ...Option) error + func Register[T any](q *Queue, name string, handler func(context.Context, T) error) + type HandlerFunc func(ctx context.Context, payload []byte) error + type Option func(*jobOptions) + func Delay(d time.Duration) Option + func MaxRetry(n int) Option + func OnQueue(name string) Option + type Options struct + Concurrency int + Driver string + Logger *slog.Logger + Queues map[string]int + RedisURL string + ShutdownTimeout time.Duration + type Queue struct + func New(options Options) (*Queue, error) + func (q *Queue) Close() error + func (q *Queue) Handle(name string, handler HandlerFunc) + func (q *Queue) Start(ctx context.Context) error + func (q *Queue) Stats(ctx context.Context) (Stats, error) + type QueueStats struct + Active int + Archived int + Completed int + Name string + Pending int + Retry int + Scheduled int + type Stats struct + Driver string + Queues []QueueStats
Go to main page