PostgreSQL schema name, e.g. "arbiter".

Unqualified table name within a schema, e.g. "email_jobs".

Create the schema arbiter's tables live in.

The schema arbiter's tables live in by default.

Create a queue's main job table, holding its pending and in-progress jobs.

Create a queue's DLQ table, where a job that runs out of attempts lands as a full snapshot plus its failure metadata.

Create the completed-job archive table. The table is logged.

A queue's own table and its companions, unqualified and unquoted, for callers that match on pg_catalog relnames.

Add the W3C trace-context columns to a queue's three job tables.

Add the per-claim token column to a queue's three job tables.

Add the payload variant label to a queue's three job tables.

Backfill NULL max_attempts to the default and set the column default. The column stays nullable for rolling deploys.

Ranking index over ready ungrouped jobs (not_visible_until IS NULL AND NOT suspended). The claim's ordered LIMIT stops the scan at the first ready rows.

Due-finder for ungrouped parked rows. The claim range-scans it by not_visible_until <= NOW() for due scheduled, backoff and expired-lease jobs.

Replace the full ungrouped ranking index with the ready-only ranking index plus the due-finder.

Index on DLQ group_key, for per-group failure listings.

Index on DLQ failed_at, for the most-recent-first listing.

Index on DLQ parent_id, for per-parent child lookups and counts.

Index on archive completed_at for the most-recent-first history listing.

Index on archive archive_expires_at. Drives the retention purge sweep.

Index on archive job_id for by-id lookups (getArchivedJobById).

Index on archive parent_id for per-tree history lookups.

Index on archive group_key for per-group history lookups.

Unique index on dedup_key. The dedup ON CONFLICT resolves against it.

Partial index on parent_id, for per-parent child lookups.

SQL for the per-table NOTIFY function, fired once per insert statement. A statement that inserted nothing notifies nothing. Channel name is quoted as a string literal.

A table's job-arrival NOTIFY trigger. Statement-level. A batch insert notifies one time.

Drop a table's job-arrival NOTIFY trigger.

Drop a table's job-arrival NOTIFY function.

Event-streaming function that receives the logical queue name and DLQ flag from each trigger. Queue names ending in _dlq stay unambiguous. A lease-extend update emits no event.

Install event-streaming triggers with explicit logical queue metadata.

Drop the schema-wide event-streaming function after its triggers are detached.

Drop current and legacy event-streaming triggers for a queue and its DLQ. The shared function is dropped separately after every queue is detached.

A table's own job-arrival NOTIFY channel: "email_jobs" -> "email_jobs_created".

Channel name used by the event streaming (SSE) system.

Per-queue NOTIFY channel for pause/resume changes. Workers LISTEN on the channel for their own queue.

Prefix for per-queue pause NOTIFY channels. The full channel name appends the queue. SQL templates build the channel from queue_name returned by a CTE.

Per-queue NOTIFY channel for force-cancel signals. The payload identifies the target worker and job. Only the matching worker reacts.

Prefix for per-queue cancel NOTIFY channels. See cancelNotifyChannel.

Per-schema NOTIFY channel for manual cron run-now requests.

Per-table NOTIFY trigger function name.

Per-table NOTIFY trigger name.

Shared event streaming trigger function name (one per schema).

Per-table event streaming trigger name.

Per-table DLQ event streaming trigger name.

Event-streaming trigger names arbiter generated before the per-queue names, each paired with whether it sits on the DLQ table.

Ownership marker stamped on every notify function and trigger arbiter installs. Sweeps match notifyObjectCommentPrefix. A trigger is current when its comment equals this exact value. Bump the version whenever createNotifyTriggerSQL changes.

The marker prefix identifying a notify object as arbiter's, across versions.

Marker stamped on notify objects installed before arbiter marked them. Sweeps match it. An adopted trigger is rebuilt.

Ownership marker stamped on every event-streaming function and trigger arbiter installs. Bump the version whenever createEventStreamingTriggersSQL changes.

The marker prefix identifying an event-streaming object as arbiter's, across versions.

Marker stamped on event-streaming objects installed before arbiter marked them. See notifyAdoptedObjectComment.

Any schema-qualified table: qualifiedTable "arbiter" "arbiter_workers" -> "arbiter"."arbiter_workers"

Qualified table name: jobQueueTable "arbiter" "email_jobs" -> "arbiter"."email_jobs"

Qualified DLQ table name: jobQueueDLQTable "arbiter" "email_jobs" -> "arbiter"."email_jobs_dlq"

Qualified archive table name: jobQueueArchiveTable "arbiter" "email_jobs" -> "arbiter"."email_jobs_archive"

Qualified results table name: jobQueueResultsTable "arbiter" "email_jobs" -> "arbiter"."email_jobs_results"

Qualified groups table name: jobQueueGroupsTable "arbiter" "email_jobs" -> "arbiter"."email_jobs_groups"

Create a queue's results table, one row per child keyed by (parent_id, child_id). Its foreign key cascades. Acking the parent clears them.

The qualified baseName_{insert,delete,update} maintenance-function names.

The 3 statement-level AFTER triggers (insertdeleteupdate) wiring a table's maintenance functions, named baseName_{insert,delete,update}.

One statement-level AFTER trigger. Drops then recreates, wiring the baseNamesuffix function over tbl with the given event and REFERENCING clause.