A job parametrized over payload, primary key, queue name, insertion timestamp, and the columns derived from the payload. The constructor is internal.

A payload's per-job variant label. Defaults to unlabelled.

The constructor name of a value, for a payload that wraps the sum it wants labelled. Needs Generic on the wrapped type.

instance HasKind Envelope where
  kindOf = Just . constructorKind . envelopePayload
  kindsFor = constructorKinds @EmailPayload

Every constructor name of a type, in declaration order.

The labels and keys a stored job carries from its payload, one field each.

The writable columns resolved from a payload at enqueue. The kind, key and prefix columns round-trip via PayloadKeys. cost is write-only.

A job read from the database.

A job ready to enqueue. Arbiter owns claim, retry, parent, rollup, and suspension state. Use the exported setters to configure enqueue fields.

Database-assigned identifier for a stored job.

User-defined payload stored as JSONB.

Queue containing a stored job.

Serial-processing group, or Nothing for an ungrouped job.

Time at which the job was inserted.

Time at which the job was last updated.

Number of attempts made so far.

Error message from the last failed attempt.

Claim priority. Lower numbers have higher priority.

Time at which a worker last claimed the job.

Earliest time at which the job can be claimed.

Deduplication strategy and key.

Attempt limit before the job moves to the DLQ.

Identifier of this job's parent in a job tree.

Snapshot of accumulated child results for a rollup finalizer.

W3C trace context captured at enqueue.

Whether the job is currently ineligible for claiming.

Worker pool that most recently claimed the job.

Monotonically increasing claim identifier.

Completed-job archive retention in seconds.

The labels and keys stamped from the payload at enqueue.

Ungrouped JobWrite with default values. For serial processing within a group, use defaultGroupedJob.

defaultJob with a group key. Jobs sharing a group key are processed serially.

Replace the payload.

Set the group key.

Set the claim priority. Lower numbers claim first.

Delay the job's first visibility.

Set the dedup key.

Override the queue's attempt limit.

Attach a trace context.

Set the archive retention, in seconds.

Transform a job's payload without changing its stored metadata.

Default attempt limit stamped onto jobs whose maxAttempts is unset.

24h in seconds, a convenience value for archiveFor.

A rollup finalizer is any job whose parentState snapshot is present (an empty object on insert, the merged child results before a DLQ move).

Effective job status. Arbiter derives status from the stored fields. The status SQL in Arbiter.Core.Sql.Jobs is its source of truth.

The wire name for a status.

Strict inverse of jobStatusToText. Unknown values are rejected.

The full payload contract. JSON round-trip for JSONB storage plus the rate-limit and concurrency declarations. Both default to unlimited.

The registry declares both admission policy kinds.

Deduplication strategy, checked on INSERT via ON CONFLICT on the dedup key.

The dedup_key and dedup_strategy column values for a DedupKey.

A job's W3C trace context.

A trace context from its two stored halves. An orphan tracestate is dropped.

Callbacks fired at each point of a job's lifecycle, for metrics, logging or tracing. An exception thrown inside one is caught and dropped.

No-op hooks. Override fields to add observability:

myHooks = defaultObservabilityHooks
  { onJobSuccess = \job startTime endTime -> do
      let duration = diffUTCTime endTime startTime
      logInfo $ "Job " <> show (primaryKey job) <> " took " <> show duration
  }

base's finally. The second action stays interruptible.

A job's primary key.

The token identifying one claim of a job.

When a claim was taken.

The transaction's clock reading.

When a handler began.

When a handler finished.

A failure message.

How long to wait before the next attempt.