Insert a job, returning it with its database-generated fields. Nothing when an IgnoreDuplicate key already exists, or a ReplaceDuplicate one names a job that is claimed, force-cancel flagged, or has children. Parent and rollup state come from insertJobTree.

insertJob over a stamp the caller shares across its inserts.

Internal tree insertion path for engine-owned parent and suspension state.

Batch-insert direct tree leaves under one parent.

insertJob over a batch in one round trip, returning the jobs inserted or replaced. Jobs sharing a dedup key within the batch collapse the way sequential insertJob calls would.

insertJobsBatch over a stamp the caller shares across its inserts.

insertJobsBatch discarding the rows, returning the count inserted.

What an insert path puts on its jobs, carrying the ambient trace context.

The stamp for the context in scope. One read covers every job inserted under it.

Insert a child's result, keyed by (parent_id, child_id). Its foreign key cascades on the parent's ack.

insertResult for several (parent id, child id, result) rows in one statement.

A parent's child results, keyed by child id.

A parent's DLQ'd children's last errors, keyed by child id.

Snapshot results into parent_state before DLQ move.

Claim up to maxJobs visible jobs, one per group. Stamps anonymousClaimant.

claimNextVisibleJobs under a given worker id.

claimNextVisibleJobs claiming up to batchSize jobs from each of maxBatches groups. Stamps anonymousClaimant.

A pool's claim statements, rendered once per capacity in [1 .. poolSize]. claimSqlFor falls back to a fresh render outside that range.

Assemble a pool's claim statements. Every input except the per-poll capacity is constant for the pool's lifetime.

claimJobs over a prebuilt ClaimSql.

claimJobsBatched over a prebuilt ClaimSql.

Add tokens to a key's bucket, capped at its max. For operator top-ups and manually-refilled policies.

Delete full, idle rate-limit buckets. Returns the number pruned.

Refill every bucket under a prefix to full. Returns the number refilled. Used to build a fixed window from a manual policy plus a cron.

Make a prefix's throttled jobs claimable again across the given queue tables, in one statement. Returns the number woken.

Wake one key's throttled jobs across the given tables, in one statement. Returns the count.

List every policy with its default/override params, bucket aggregates, and live throttled count across the given queue tables.

One prefix's policy view with bucket aggregates and live throttled count.

Whether a rate-limit policy exists for a prefix.

List a prefix's buckets with effective max and fill fraction, paginated.

List every concurrency pool with its default/override limit and live key and in-flight aggregates.

One prefix's concurrency pool view with live aggregates.

List a prefix's keys with effective cap and fill fraction, paginated.

Set or clear a policy's override params. Returns rows affected (0 if absent).

Apply a pool's override-limit patch (retunes every key under the prefix). Returns rows affected.

Delete drained concurrency rows with no live job across the given tables. Returns the number pruned. A key whose advisory try-lock is contended is skipped until the next pass.

Lock the count rows, then recount those keys under the lock. A key seeded after the lock pass is left to its triggers.

Rebuild the counts when a crash truncated the UNLOGGED table. Returns the rows it recounted.

Reconcile then prune, skipped when no concurrency key exists. Returns the rows recounted and pruned.

Ack a completed job. Deletes a standalone one, suspends a parent whose children are still running, and wakes a parent whose last child finished. A child's ack takes the parent's advisory lock. Returns 1, or 0 for a job already gone.

Inner ack logic, run inside the caller's transaction.

ackJob over a batch in one statement, locking the distinct parents to serialize with concurrent sibling acks.

Inner batch ack, run inside the caller's transaction.

Take the advisory lock of every distinct parent named, ascending, before any row lock the caller goes on to take.

Lock every job named and all of its descendants, in one descending pass.

Apply lockJobTrees to the complete tree of each named job. Use these locks before tree cancellation.

Whether the caller already took the parent and tree locks over its whole set.

Whether acking this job tees it into the archive (positive archiveFor).

Extend a job's visibility timeout.

setVisibilityTimeout over a batch, reporting each row through VisibilityUpdateInfo.

What a batch visibility update found for one job.

Park a failed job for its retry backoff, recording the error. Returns 0 for a job another worker holds.

Soft-nack a job. Hands back the attempt the claim consumed and records no failure. Returns 0 for a job another worker holds.

nackJob over a batch in one statement, returning the ids nacked. Jobs another worker holds are absent.

Move a job to the DLQ, cascading a rollup parent's descendants with it and waking the parent of a child. Returns 0 for a job another worker holds.

moveToDLQ driven by scalar fields, for callers without a typed JobRead.

moveToDLQ over a batch, each job under its own error message. Jobs another worker reclaimed are skipped. Returns the number moved.

Retry a job from the DLQ, re-inserting it with a fresh attempt count. The dedup key is left behind.

Whether a DLQ job with the given id exists.

List DLQ jobs, most recently failed first.

List a parent's DLQ'd children, most recently failed first.

Count DLQ jobs matching a parent_id.

Delete a DLQ job, resuming its parent when no sibling is left.

Delete multiple jobs from the dead letter queue, resuming any parents left childless. Returns the total number of DLQ jobs deleted.

Delete force-cancel-flagged jobs owner holds or no live lease holds, resuming any parents left childless. Returns the ids it deleted.

List archived jobs (most recent first).

List archived (completed) jobs with composable filters and a typed sort (defaulting to most recent first).

Fetch a single archived job by its original job id.

List archived jobs in a group, most recent first.

Count archived jobs with composable filters.

Purge expired archived jobs across all queues. Each row uses its archive_expires_at value. Return the total rows purged and queues with errors. Run one small batch at each reaper tick.

Delete one archived job by its archive primary key. Returns rows deleted.

Delete archived jobs by archive primary key. Returns rows deleted.

Re-enqueue an archived job as a fresh standalone job, keeping the archive row. Returns the new job, or Nothing when the archive row no longer exists.

Store a completed root job's result on its archive row. No-ops when the job was not archived. Returns rows updated.

updateArchiveResult for several (job id, result) pairs in one statement.

A narrowing predicate on a job listing. FilterJobId and the completed_at range name DLQ and archive columns.

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

List filtered jobs, newest first.

List filtered jobs under an explicit sort spec. Nothing for both sort arguments orders by id DESC.

listJobsFilteredOrdered that also returns each job's derived status.

Count jobs with composable filters.

List filtered DLQ jobs, most recently failed first.

List filtered DLQ jobs under an explicit sort spec. Nothing for both sort arguments orders by failed_at DESC.

Count DLQ jobs with composable filters.

List jobs, newest first.

Whether a job with the given id exists in the table, without decoding it.

Fetch a job by id.

getJobById that also returns the job's derived status.

Get a single job by its dedup key.

Get all jobs for a specific group key.

Delete a job by id. Returns 0 for a job with children, which cancelJobCascade takes. A deleted child with no siblings left resumes its parent for a completion round.

cancelJob over several ids in one transaction. The last sibling cancelled finds the parent childless and resumes it. Locks the union of parents and rows first. Returns the number deleted.

Make a delayed or retrying job immediately visible. Refuses an in-flight job.

Per-status breakdown of a queue. The per-status counts partition the queue and sum to totalJobs, mirroring the derived job status taxonomy.

Decodes the single aggregate row produced by getQueueStatsSQL, whose select list is built from these same columns.

The per-status depths a QueueStats carries.

A landing-overview row: a queue's stats plus its pause state.

A queue's per-status counts and backlog ages.

Every queue's stats plus pause state in one query, for the landing overview.

Count every job in a table.

Count a group's jobs.

Count a queue's DLQ jobs.

List jobs filtered by parent_id with pagination.

Count jobs matching a parent_id.

Child counts as (total, paused) per parent id, over a batch. Parents with none are absent.

DLQ child counts per parent id, over a batch. Parents with none are absent.

Suspend a parent's claimable children. In-flight ones are left alone. Returns the number suspended.

Resume a parent's suspended children. Returns the number resumed.

Delete a job and every descendant under it, resuming the parent of a root that is itself a child. Returns the number deleted.

Delete a whole job tree, named by any node in it. Walks up to the root, then deletes from there down. The root has no parent to resume. Returns the number deleted.

Cascade-cancel a job subtree. Flags still-live claimed jobs, deletes the rest, and NOTIFYs the queue's cancel channel for every claimed job affected. Workers async-cancel the matching handler thread on receipt.

Suspend a job, making it unclaimable. Refuses an in-flight job.

Resume a suspended job, making it claimable again.

Where a queue's next groups pass resumes. The summary window and the emptied scan walk the key space independently.

What one queue's groups pass did: the rows it rewrote, whether its missing-summary repair threw, and where the next pass resumes.