Struct Queue 

pub struct Queue {
    pub dropped: u64,
    /* private fields */
}

Fields

dropped: u64

Cumulative dropped count (in-memory or on-disk FIFO eviction).

Implementations

impl Queue

pub fn open(dir: PathBuf) -> Result<Self>

pub fn append(&mut self, r: &Record) -> Result<bool>

Append and return true if a roll happened (current segment was closed).

pub fn force_roll(&mut self) -> Result<Option<PathBuf>>

Force roll even if segment isn’t full (used on tick flush). Returns Ok(None) if nothing to roll.

pub fn ready_segments_sorted(&self) -> Result<Vec<PathBuf>>

Closed, immutable segments ready to be sent.

pub fn segments_sorted(&self) -> Result<Vec<PathBuf>>

pub fn claim_oldest_segment(&self) -> Result<Option<PathBuf>>

pub fn complete_claim(&self, path: &Path) -> Result<()>

pub fn restore_claim(&self, path: &Path) -> Result<Option<PathBuf>>

pub fn delete(&self, path: &Path) -> Result<()>

pub fn stats(&self) -> Result<QueueStats>