A narrowing predicate on a job listing. Filters combine with AND.

The table a JobFilter narrows.

Sortable columns on the main jobs table.

Underlying SQL column name for a JobSortColumn.

Sortable columns on the DLQ table. DlqId is the DLQ primary key and DlqJobId the original job id.

The DLQ column a sort key names.

Sortable columns on the archive table. ArchiveId is the archive primary key and ArchiveJobId the original job id.

The archive column a sort key names.

Sort direction.

A sort direction as a query parameter.

A throttle-deferred job with a live marker, still parked. Claiming clears the marker.

The derived job status. Its string values match jobStatusToText. An exhausted job is visible but out of attempts, awaiting the reaper's DLQ sweep.

The rows a claim considers, over a row alias: unsuspended, uncancelled, visible, and within the attempt budget.

List filtered jobs without the derived status.

List filtered jobs with status as a trailing column. The caller attaches the row decoder.

Count filtered jobs through the status subquery.

Fetch a single job by id with its derived status trailing column. The caller attaches the row decoder.

ORDER BY for the jobs table. Defaults to id DESC.

ORDER BY for the DLQ table. Defaults to failed_at DESC.

ORDER BY for the archive table. Defaults to completed_at DESC.

Count the rows of src under a dynamic WHERE.

The WHERE clause a set of filters narrows a listing of one table by. Empty for no filters.

The job read columns except id. The archive INSERT copies them with the main table's id as job_id.

Job columns carried through a DLQ round-trip. The read columns except id and last_error, plus write-only rate_limit_cost.

The job columns a DLQ retry carries back to the main table, as a column list.

requeuedCols as select expressions, with the attempt limit clamped. Each column in edited is read through reader.

The job columns an archive re-enqueue carries, as a column list. No parent link.

enqueuedAgainCols as select expressions, with the attempt limit clamped. Each column in edited is read through reader.

The job read columns, in codec order, for SELECT and RETURNING.

Insert a job. The write fragment carries the column list and parameters.

Insert under the replace dedup strategy. Replaces an existing job that is idle and childless in the main queue and the DLQ. ON CONFLICT DO UPDATE fires the groups UPDATE trigger, which maintains a cross-group move.

Batch insert over unnested parallel arrays. An ignore-dedup job is skipped on conflict. A replace-dedup job updates an idle existing row. A row whose parent is absent is skipped.

insertJobsBatchSQL with no RETURNING.

Fetch a job by id.

Fetch a job by its dedup key. The partial unique index guarantees at most one row.

Delete a job by id. Refuses one with children, which cancelJobCascadeSQL takes. A deleted child with no siblings left resumes its parent for a completion round.

UNION ALL of body over each job table, passing its raw name and schema-qualified reference.