axa-postgres-job-queue

A Postgres job queue for Axum services, from the axa family: a pool of job loops with per-job-type limits, delayed jobs, priorities, a job's status by id, and recurring schedules that enqueue each due time once across replicas.

Jobs live in one axa_queue table and are claimed with FOR UPDATE SKIP LOCKED, so no broker is needed. Schedules live in axa_schedule, and each due time becomes an ordinary job, so retries, status, limits, and recovery are the queue's.

A job row is state, and retention deletes it. A person's act on a job is a record. cancel and retry take the caller's transaction, a by, and a reason, and append the act to axa_job_acts with the change, so the service's own audit row commits with both. That table is only ever inserted into, and its triggers refuse every change. Queue::acts reads a job's acts, which outlive its row.

Enable it through the queue feature of axa, which adds the BackgroundWorker trait over it, or depend on this crate alone and register closures. See the crate documentation for usage, and the guide for what a service changes.

License

See LICENSE.md.