taskqueue

type Config struct {
	Name        string
	Workers     int           // per priority lane (Low gets half)
	MaxAttempts int           // default 5
	BaseDelay   time.Duration // exponential retry base, default 500ms
	Logger      *slog.Logger
}

type Envelope struct {
	ID         string          `json:"id"`
	Type       string          `json:"type"`
	Payload    json.RawMessage `json:"payload"`
	Attempt    int             `json:"attempt"`
	EnqueuedAt time.Time       `json:"enqueued_at"`
}

type Handler func(ctx context.Context, env Envelope) error

type Priority int8

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