Struct DispatchQueue 

pub struct DispatchQueue<'a> {
    pub(super) conn: &'a Mutex<Connection>,
}

Fields

conn: &'a Mutex<Connection>

Implementations

impl<'a> DispatchQueue<'a>

pub fn upsert(&self, q: &QueuedDispatch) -> Result<()>

Upsert a pending Dispatch for (hostname, rollout_id). Idempotent: re-emission of QueueDispatch for the same pair overwrites target_closure / soak_due_at (the reducer’s view always wins).

pub fn take_for_host(&self, hostname: &str) -> Result<Option<QueuedDispatch>>

Atomically claim and delete the next queued Dispatch for hostname. Returns Ok(None) if no dispatch is pending.

Atomicity: SELECT + DELETE in one txn under the connection mutex. SQLite’s WAL mode + the single-writer Mutex make this race-free even with multiple long-poll handlers (no two see the same row).

pub fn peek_for_host(&self, hostname: &str) -> Result<bool>

Peek without claiming. Used by the long-poll worker after a wake event to decide whether to actually fire take_for_host (avoids a txn on every wake when the queue is empty for this host).