jobs

Documentation

Overview

Package jobs runs durable SQLite jobs with bounded leases and retry backoff.

Index

• func Backoff(attempt int) time.Duration
• func Permanent(err error) error
• type Handler
• type PermanentError
  • func (e *PermanentError) Error() string
  • func (e *PermanentError) Unwrap() error
• type Runner
  • func New(repo *repository.Repository, handlers map[string]Handler, workers int, ...) *Runner
  • func (r *Runner) Start(ctx context.Context)
  • func (r *Runner) Wait()

Functions

func Backoff

func Backoff(attempt int) time.Duration

Backoff returns exponential retry delay with bounded jitter.

func Permanent

func Permanent(err error) error

Permanent marks an error as non-retryable.

Types

type Handler

type Handler func(context.Context, model.Job) error

Handler processes one claimed job and must be idempotent.

type PermanentError

type PermanentError struct{ Err error }

PermanentError prevents a retry for invalid or unrecoverable work.

func (*PermanentError) Error

func (e *PermanentError) Error() string

func (*PermanentError) Unwrap

func (e *PermanentError) Unwrap() error

type Runner

type Runner struct {
	// contains filtered or unexported fields
}

Runner owns a fixed-size worker pool.

func New

func New(repo *repository.Repository, handlers map[string]Handler, workers int, poll, lease time.Duration, logger *slog.Logger) *Runner

New creates a durable worker runner.

func (*Runner) Start

func (r *Runner) Start(ctx context.Context)

Start runs workers until context cancellation and returns immediately.

func (*Runner) Wait

func (r *Runner) Wait()

Wait waits for all worker goroutines after cancellation.