A queue's table name, payload type, and handler result type. A type data constructor. It takes no promotion tick.

A queue whose handlers store no result. A module with its own Queue type needs import Arbiter.Core hiding (Queue) or a qualified import.

The desired state reconciled after a schema's tracked migrations run.

Notify triggers on, event streaming off, unlogged rate-limit buckets.

Reject queue names that generate a schema-wide arbiter table, or that generate object or channel names PostgreSQL truncates into each other. The length limit is where two of a queue's generated names collide.

The longest queue name whose generated identifiers survive PostgreSQL's 63-byte truncation distinct. Derived by rendering a probe queue's own DDL at each length.

Migrate every queue in a registry into one schema. The schema itself is created first, outside migration tracking.

type AppRegistry =
  '[ Queue "email_jobs" EmailPayload
   , Queue "order_jobs" OrderPayload
   ]

main :: IO ()
main = do
  result <- runMigrationsForRegistry
              (Proxy @AppRegistry)
              "host=localhost dbname=mydb"
              "arbiter"
              defaultMigrationConfig

Run migrations for multiple tables within a single schema, seeding the given rate-limit policies. On migration success, reconciles the policy and bucket tables on the same connection. The table list must be the schema's whole queue set. Reconciliation treats an omitted queue as removed and drops its notify and event-streaming objects.

One queue's tracked migrations, each under its own version identifier. reconcileOptionalTriggers owns the optional notify and event-streaming objects.

The schema-level migrations, run once per schema. Exposed for the golden suite. reconcileOptionalTriggers owns the optional notification and event-streaming objects.

Admission policy rows to seed after a successful migration.

Seeds for a deployment with no admission policies.

Which admission trigger kinds a table's payload declares. Trigger migrations are install-only. A kind removed from a payload keeps its triggers.

Install every admission trigger kind.

conflictingPrefixes specialized to policy rows.

A sum-type denoting the result of a migration.