Struct OutboundQueue 

pub struct OutboundQueue {
    dir: PathBuf,
}

Disk-backed queue handle. Cheap to clone via Arc.

Fields

dir: PathBuf

Implementations

impl OutboundQueue

pub fn open(state_dir: &Path) -> Result<Self>

Open / create the queue directory. Idempotent.

pub fn enqueue(&self, event: &QueuedEvent) -> Result<PathBuf>

Atomically persist an event. fsync before rename ensures the payload bytes hit disk before the directory entry flips; a crash between fsync and rename leaves a .tmp file that the drainer ignores.

pub fn scan_pending(&self) -> Result<Vec<QueuedEvent>>

All pending events, sorted ascending by seq. Filenames sort lexicographically thanks to the 20-char zero-padded seq prefix; the BTreeMap-by-seq pass below is belt-and-braces in case the scan picks up files with unexpected sort order (rare on POSIX but defensible).

pub fn mark_sent(&self, event: &QueuedEvent) -> Result<()>

Delete the on-disk file for event. Called after a successful POST to /v1/agent/events.

pub fn dir(&self) -> &Path

Trait Implementations

impl Clone for OutboundQueue

fn clone(&self) -> OutboundQueue

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.