timgit / pg-boss / 21876257184

100%

push

github

feat: new queue policy key_strict_fifo (#691)

* Add FIFO queue design document

Documents the design for strict FIFO ordering per singletonKey with
head-of-line blocking on failure. Includes new 'fifo' queue policy,
database index strategy, and API changes.

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>

* Add singleton_strict_fifo queue policy for strict ordering per singletonKey

Implements a new 'singleton_strict_fifo' queue policy that guarantees strict
FIFO ordering per singletonKey with head-of-line blocking on failure:

- Only one job active per singletonKey at a time
- Queue blocks during retry state (next job waits for retry to complete)
- Queue blocks permanently on failure until manual intervention
- Different singletonKeys process in parallel

API:
- createQueue(name, { policy: 'singleton_strict_fifo' })
- getBlockedKeys(name) - returns singletonKeys blocked by failed jobs
- Jobs require a singletonKey (validated at send time)

Unblocking a failed queue:
- deleteJob() - skip the failed job, continue with next
- retry() - retry the failed job

Implementation uses a partial unique index on (name, singleton_key) for
states (active, retry, failed) to enforce blocking at the database level,
ensuring correctness even with multiple concurrent workers.

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>

* Update design doc to reflect singleton_strict_fifo implementation

- Rename policy from 'fifo' to 'singleton_strict_fifo'
- Document use of createQueue() instead of separate createFifoQueue()
- Add insert() validation section
- Add parallel processing section
- Document implementation details and test coverage

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>

* Rename test file and update descriptions for singleton_strict_fifo

- Rename fifoTest.ts to singletonStrictFifoTest.ts
- Update describe block and all test descriptions to use singleton_strict_fifo
- No duplicate tests, all 24 tests (12 per partition mode) verified... (continued)

699 of 759 branches covered (92.09%)

19 of 19 new or added lines in 3 files covered. (100.0%)

1272 of 1272 relevant lines covered (100.0%)

202.03 hits per line