Struct JobQueues 

pub struct JobQueues<K: Ord> { /* private fields */ }

Deterministic, typed FIFO queues driven only by explicit caller operations.

Implementations

impl<K: Clone + Ord> JobQueues<K>

pub fn new(admission: AdmissionLimit) -> Self

Creates empty queues with a lifetime admission limit.

pub fn remaining_admission(&self) -> usize

Returns capacity remaining under the lifetime admission bound.

pub fn enqueue( &mut self, class: K, job: impl FnOnce(&mut Self) + 'static, ) -> Result<JobReceipt, CheckpointError>

Enqueues one job at the tail of its class FIFO.

pub fn cancel(&mut self, id: JobId) -> JobReceipt

Cancels a queued job. Cancellation is idempotent and receipt-bearing.

pub fn drain(&mut self, class: K, work: WorkLimit) -> DrainReceipt<K>

Drains at most work jobs from one class.

pub fn checkpoint( &mut self, class: K, work: WorkLimit, ) -> Result<CheckpointReceipt<K>, CheckpointError>

Drains one class to empty, including jobs enqueued reentrantly into it.

Fails closed if empty cannot be reached within work; unrelated job classes remain untouched.