queue

Jun 30, 2026

Changes in this version

+ var ErrUnknownKind = errors.New("queue: no handler registered for kind")

+ type JobFunc func(ctx context.Context, t Task) error

+ func Retry(cfg retry.Config, fn JobFunc) JobFunc

+ type Mux struct

+ func NewMux(opts ...MuxOption) *Mux

+ func (m *Mux) Handle(ctx context.Context, t Task) error

+ func (m *Mux) Register(kind string, fn JobFunc) error

+ type MuxOption func(*Mux)

+ func WithFallback(fn JobFunc) MuxOption

type Options

+ RetryDelay time.Duration

Jun 26, 2026

Changes in this version

+ var ErrLeaseLost = errors.New("queue: lease lost")

+ func Schema() string

+ type InMem struct

+ func NewInMem(leaseTimeout time.Duration) *InMem

+ func (q *InMem) Claim(_ context.Context, now time.Time, limit int) ([]Task, error)

+ func (q *InMem) Len() int

+ func (q *InMem) MarkDone(_ context.Context, t Task, _ time.Time) error

+ func (q *InMem) MarkFailed(_ context.Context, t Task, errMsg string, terminal bool, now time.Time) error

+ func (q *InMem) Schedule(_ context.Context, p ScheduleParams) (bool, error)

+ type Options struct

+ LeaseTimeout time.Duration

+ type PG struct

+ func NewPG(log *logger.Logger, db *sqlx.DB, opts Options) *PG

+ func (q *PG) Claim(ctx context.Context, now time.Time, limit int) ([]Task, error)

+ func (q *PG) Cleanup(ctx context.Context, before time.Time) (int64, error)

+ func (q *PG) EnsureSchema(ctx context.Context) error

+ func (q *PG) MarkDone(ctx context.Context, t Task, _ time.Time) error

+ func (q *PG) MarkFailed(ctx context.Context, t Task, errMsg string, terminal bool, now time.Time) error

+ func (q *PG) Schedule(ctx context.Context, p ScheduleParams) (bool, error)

+ type Queue interface

+ Claim func(ctx context.Context, now time.Time, limit int) ([]Task, error)

+ MarkDone func(ctx context.Context, t Task, now time.Time) error

+ MarkFailed func(ctx context.Context, t Task, errMsg string, terminal bool, now time.Time) error

+ Schedule func(ctx context.Context, p ScheduleParams) (inserted bool, err error)

+ type ScheduleParams struct

+ Delay time.Duration

+ Kind string

+ Name string

+ Payload []byte

+ type Task struct

+ Attempts int

+ CreatedAt time.Time

+ ID int64

+ Kind string

+ LastError string

+ LeaseID string

+ Name string

+ Payload []byte

+ RunAt time.Time