index

Interfaces

Interface	Description
JobAuthorityAssertion	Enqueue-hop identity assertion stored with the authority grant.
JobEntity	-
JobRequest	Capped request payload delivered to the target operation (≤ 16 KB serialized).
JobResult	Outcome of a terminal or failed attempt; `error_body` only on failure (≤ 8 KB).

Type Alias	Description
JobAuthority	Root grant for the job chain, including the embedded enqueue assertion. Wire form omits `assertion` (returned separately as `authority_assertion`).
JobEntityTest	-
JobStatus	-
JobTerminalReason	-

Variable	Description
cancelByIdJob	Cancel a pending/retrying job (`terminal_reason: cancelled-by-admin`). Running and terminal jobs return `JobNotCancellableError`.
cancelByOriginalRequestIdJob	Cancel every pending/retrying job in a chain (`terminal_reason: cancelled-by-chain`). Running and terminal jobs are left alone. Returns the cancelled rows (possibly empty).
claimNextJob	Atomically claim the highest-priority eligible job.
countByOriginalRequestIdJob	Count all jobs sharing an `original_request_id` (spawn-cap / lineage).
countByStatusJob	Counts of jobs grouped by status (for the `jobs_queue_depth` gauge). Statuses with zero jobs are omitted.
createJob	-
deleteExpiredTerminalJob	Retention sweep: delete terminal jobs older than `cutoff`. Returns the number of rows deleted.
getByIdJob	-
heartbeatJob	Refresh `heartbeat_at` for a running job (stall detection).
jobsDb	-
jobTable	-
listJob	List jobs with optional filters, newest first (`created_at` desc, then `id`).
listRunningJobsJob	Returns all jobs currently in `running` status (for stall detection).
recordAttemptResultJob	Record a delivery attempt outcome. Only transitions from `running`.
recoverStalledJob	Recover stalled deliveries: running jobs in `ids` become `retrying` if attempts remain, else `dead` with `terminal_reason: exhausted`. Returns the affected rows.
retryByIdJob	Re-queue a dead/cancelled job as pending with a full attempt reset. Other statuses return `JobNotRetryableError` (409-style).