queue

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

type Options struct {
	// Table is the backing table name (default "queue_tasks").
	Table string
	// LeaseTimeout is how long a claimed task stays leased before another
	// consumer may reclaim it, guarding against a consumer that died mid-process
	// (default 5m).
	LeaseTimeout time.Duration
}

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

type Queue interface {
	// Schedule enqueues a task, returning inserted=false if Name already exists.
	Schedule(ctx context.Context, p ScheduleParams) (inserted bool, err error)
	// Claim leases up to limit ready tasks (run_at <= now and not currently
	// leased), bumping their attempt count. Each returned Task carries a fresh
	// LeaseID that MarkDone/MarkFailed must echo back.
	Claim(ctx context.Context, now time.Time, limit int) ([]Task, error)
	// MarkDone acknowledges successful processing and removes the task.
	MarkDone(ctx context.Context, t Task, now time.Time) error
	// MarkFailed records a failure. terminal=true parks the task as a dead letter;
	// terminal=false releases the lease so a later Claim retries it.
	MarkFailed(ctx context.Context, t Task, errMsg string, terminal bool, now time.Time) error
}

type ScheduleParams struct {
	// Name is an optional dedup key. When set, scheduling the same Name twice is a
	// no-op (Schedule reports inserted=false). When empty, the queue assigns a
	// unique name so every call enqueues a distinct task.
	Name string
	// Kind routes the task to a handler; required.
	Kind string
	// Payload is the opaque task body.
	Payload []byte
	// Delay postpones the earliest claim time (RunAt = now + Delay). Zero means
	// claimable immediately.
	Delay time.Duration
}

type Task struct {
	ID        int64     `db:"id"`
	Name      string    `db:"name"`
	Kind      string    `db:"kind"`
	Payload   []byte    `db:"payload"`
	CreatedAt time.Time `db:"created_at"`
	RunAt     time.Time `db:"run_at"`
	Attempts  int       `db:"attempts"`
	LeaseID   string    `db:"lease_id"`
	LastError string    `db:"last_error"`
}