Versions in this module Expand all Collapse all v1 v1.0.0 Jul 3, 2026 Changes in this version + func CanonicalName(job Job) string + func Register(class string, factory func() Job) + type ClassNamer interface + Class func() string + type DispatchOpts struct + MaxAttempts int + type Driver interface + Ack func(ctx context.Context, p *Payload) error + Dead func(ctx context.Context, p *Payload) error + Pop func(ctx context.Context, queue string) (*Payload, error) + Push func(ctx context.Context, queue string, p *Payload) error + Release func(ctx context.Context, p *Payload, delay time.Duration) error + type Job interface + Handle func(ctx context.Context) error + type Manager struct + func NewManager(driver Driver, opts Options) *Manager + func (m *Manager) Dispatch(ctx context.Context, queue string, job Job, delay time.Duration, ...) error + func (m *Manager) Stop() + func (m *Manager) Work() + type Options struct + Logger *slog.Logger + PollInterval time.Duration + Queues []string + Workers int + type Payload struct + Attempts int + AvailableAt time.Time + Class string + Data json.RawMessage + ID string + MaxAttempts int + Queue string + func (p *Payload) Unmarshal() (Job, error)
Go to main page