Documentation

Set a pool's operator override limit. Nothing leaves it untouched. Just v writes v (a null clears the override back to the default).

Every concurrency_key held by a live job, unioned across the queue tables.

Lock count rows with no live job, in the triggers' key order. Returns the locked keys.

Delete the passed locked keys that are still dead under a fresh snapshot.

Try an exclusive per-key advisory lock over the dead keys, pairing the insert trigger's shared lock. Never waits. Returns the keys acquired.

Lock every count row in key order.

Recount in_flight for the passed locked keys and seed a row for a live key that has none. Writes the rows the caller locked and fresh inserts. Run after lockConcurrencyCountsSQL in one transaction. Returns the number repaired.

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

Single-prefix variant of listConcurrencyPoliciesSQL.

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

Whether any concurrency key exists.

Whether a crash truncated the count table (a live keyed job has no count row).