Struct BinlogReader 

pub struct BinlogReader { /* private fields */ }

Reader for replaying events from a binlog file.

Implementations

impl BinlogReader

pub fn open(path: impl Into<PathBuf>) -> Result<Self>

Open an existing binlog file for reading.

pub fn read_all(&self) -> Result<Vec<OpEvent>>

Read all events from the binlog.

pub fn read_after(&self, after_op_id: &str) -> Result<Vec<OpEvent>>

Read events starting after a given op_id (for replay from a snapshot).

pub fn read_until(&self, until_op_id: &str) -> Result<Vec<OpEvent>>

Read events up to and including a given op_id.

pub fn validate_lineage(&self) -> Result<Vec<String>>

Validate the parent_id chain: each event’s parent_id should match the previous event’s op_id (except the first event).

pub fn validate_hash_chain(&self) -> Result<Vec<String>>

Validate hash chain integrity (if events have event_hash/prev_event_hash).

pub fn tip(&self) -> Result<Option<OpEvent>>

Return the last event in the binlog (the current tip).

pub fn count(&self) -> Result<usize>

Count events in the binlog.