Expand description
Bounded work queues with backpressure (RFC-036 §7, §10).
Each BoundedQueue<T> holds at most capacity items. Callers must
check is_full before pushing; the scheduler applies upstream
backpressure when any downstream queue reports full.
This implementation is synchronous and single-threaded, matching the existing orbok-workers execution model. Async channels can be layered in a future RFC without changing this API.
Structs§
- Bounded
Queue - A single bounded queue of
IndexJobs, ordered by priority then insertion order (RFC-036 §8). - Queue
Set - The complete set of bounded queues for the scheduler (RFC-036 §7).