Struct CursorStore 

pub struct CursorStore { /* private fields */ }

File-backed last-ACK cursor for one node stream. Writes are atomic (tmp + rename).

Implementations

impl CursorStore

pub fn new(dir: &Path, node_id: &str, channel_id: u32) -> Self

pub fn dir_from_env() -> Option<PathBuf>

Resolve the cursor directory: HATCHERY_DRAIN_STATE_DIR, else <HATCHERY_SERVER_DATA_DIR>/drain-cursors, else none (memory only).

pub fn load(&self) -> u64

pub fn save(&self, seq: u64) -> Result<()>

Trait Implementations

impl Clone for CursorStore

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CursorStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.