engine

Oct 12, 2026

Changes in this version

+ func IsPermanent(err error) bool

+ func LastAttempt(attempt, maxAttempts int) bool

+ func WillRetry(err error, attempt, maxAttempts int) bool

Jul 27, 2026

Changes in this version

type Outcome

+ func ClassifyOutcome(err error) Outcome

+ type OutcomeError interface

+ AsyncOutcome func() Outcome

type OutcomeKind

+ const OutcomeSkip

Jul 26, 2026

Changes in this version

+ func ExtractTraceContext(ctx context.Context, meta map[string]string) context.Context

+ func InjectTraceContext(ctx context.Context, meta map[string]string) map[string]string

type Engine

+ func (e *Engine) Done() <-chan struct{}

type Settings

+ DeadRetention time.Duration

Jul 25, 2026

Changes in this version

+ func Backoff(attempt int) time.Duration

+ type Classifier func(error) Outcome

+ type Config struct

+ Acker func(ctx context.Context, id, leaseToken uuid.UUID, result json.RawMessage) error

+ Logger *slog.Logger

+ Settings Settings

+ Source driver.Source

+ Store driver.Store

+ type Engine struct

+ func New(cfg Config) *Engine

+ func (e *Engine) Ready() <-chan struct{}

+ func (e *Engine) Register(k Kind) error

+ func (e *Engine) Start(ctx context.Context) error

+ func (e *Engine) Started() bool

+ type Kind struct

+ Classify Classifier

+ Concurrency int

+ Handler func(ctx context.Context, job driver.Job) (json.RawMessage, error)

+ MaxAttempts int

+ MaxAttemptsSet bool

+ Name string

+ Timeout time.Duration

+ type Outcome struct

+ Delay time.Duration

+ Kind OutcomeKind

+ Reportable bool

+ type OutcomeKind int

+ const OutcomeAbort

+ const OutcomeRetry

+ const OutcomeSnooze

+ type Settings struct

+ CompletedRetention time.Duration

+ FetchBatchSize int

+ FetchCooldown time.Duration

+ FetchPollInterval time.Duration

+ IdleBackoffMax time.Duration

+ LeaseTTL time.Duration

+ MaxConcurrency int

+ MaxReaps int

+ PromoteInterval time.Duration

+ ShutdownDrain time.Duration

+ StatsRetention time.Duration

+ VacuumInterval time.Duration