Struct QueuePause 

pub struct QueuePause { /* private fields */ }

Dispatch gate shared through AppState, toggled by POST /api/queue/pause and POST /api/queue/resume. When paused the dispatch loops stop pulling new jobs off the channel; the job already running on a worker finishes untouched. Cheap to poll (a single relaxed-ish atomic) so it can sit at the top of every loop iteration.

Implementations

impl QueuePause

pub fn new() -> Arc<Self>

pub fn pause(&self) -> bool

Pause new-job dispatch. Returns true iff this call flipped the state (was running); idempotent repeat pauses return false so the route can suppress a duplicate queue_paused event.

pub fn resume(&self) -> bool

Resume dispatch and wake every gated loop. Returns true iff this call flipped the state (was paused).

pub fn is_paused(&self) -> bool

pub async fn wait_if_paused(&self)

Park the caller while paused, returning as soon as dispatch is resumed (immediately when not paused). Registers the wakeup before the second flag check so a concurrent resume()’s notify_waiters() can’t slip between the check and the await — the classic lost-wakeup race — and re-loops in case of a spurious wake.