Struct EventLog 

pub struct EventLog { /* private fields */ }

Append-only binary event log, one file per (symbol, stream_kind).

Implementations

impl EventLog

pub fn new(root: impl Into<PathBuf>) -> Result<Self>

Create an EventLog rooted at root. Creates the directory if absent.

pub fn append( &self, symbol: &str, stream_kind: &str, record: &EventRecord<'_>, ) -> Result<()>

Append one record to {symbol}/{stream_kind}.bin.

Creates subdirectory and file on first call.

pub fn read_all( &self, symbol: &str, stream_kind: &str, ) -> Result<Vec<(i64, Vec<u8>)>>

Read all records from {symbol}/{stream_kind}.bin.

Returns (ts_ms, payload_bytes) pairs. Truncated tail records are silently skipped (truncation-safe).

pub fn read_range( &self, symbol: &str, stream_kind: &str, from_ms: i64, to_ms: i64, ) -> Result<Vec<(i64, Vec<u8>)>>

Read records with ts_ms in [from_ms, to_ms] (inclusive).

pub fn iter(&self, symbol: &str, stream_kind: &str) -> Result<EventLogIter>

Lazy iterator over records — avoids loading the entire file into memory.

Returns an iterator that yields Ok((ts_ms, payload)) or Err on I/O failure. Truncated tail records produce None (iterator stops cleanly).