Arbiter.Concurrency

A payload's per-job policy selection. Defaults to unbounded. Only capped payloads need an instance.

A selective description of the concurrency key for a payload. Evaluation returns the job key. Static inspection returns the reachable policies.

A selective description over a payload. Evaluation for a job returns an a. Static inspection returns the reachable policies.

This payload is unbounded.

Cap by a fixed policy, keyed by a per-job suffix, such as a tenant id.

Cap by a fixed policy under one shared key.

The first selector when the predicate holds, else the second. Policy collection inspects both branches.

N-way chooseWhen. Maps the job to a finite tag, then each tag to its selector. Policy collection evaluates every tag in [minBound..maxBound]. The tag's Bounded/Enum and the selector must be total over k.

The constraint that lets the migration collect a registry's declared policies.

A concurrency policy. At most cpLimit jobs are in flight per key under cpPrefix. The default is seeded. An operator override on the policy takes precedence.

A policy named prefix admitting at most limit concurrent jobs per key. The cap is floored at 1. Pause it with setConcurrencyLimit policy {cpLimit = 0}. The prefix must not contain :, the key separator. The migration enforces this.

A policy that admits jobs under a named prefix.

A resolved concurrency key with a policy prefix and per-key suffix. The stored form is prefix:suffix.

A concurrency policy with its default and override limits plus live key and in-flight stats. The effective cap is overrideLimit when set, else defaultLimit.

A single key's in-flight count, its effective cap, and fill fraction.

A patch over a concurrency policy's override limit. Nothing leaves it unchanged, Just Nothing clears the override (reverts to the default), and Just (Just v) sets it.

Apply a concurrency policy's override-limit patch on its policy row, retuning every key under the prefix live. Lowering it never preempts in-flight jobs. Returns rows affected.

Override the policy's limit with its cpLimit, until it is cleared. Returns rows affected.

Drop a concurrency policy's override. Its declared limit applies again. Returns rows affected.

Delete drained concurrency rows with no live job. Returns the number pruned.

Recompute the concurrency counts from live jobs, repairing any trigger drift. Returns the rows repaired.

Rebuild the concurrency counts when a crash truncated the UNLOGGED table. Returns the rows repaired.

Reconcile then prune. Skipped when no concurrency key exists. Returns the rows repaired plus the rows pruned.

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

List a prefix's keys with effective cap and in-flight fill fraction, fullest first.

One prefix's concurrency policy with its default/override limit and live aggregates. Nothing when the prefix has no policy.

Whether a concurrency policy exists for a prefix.