Struct WalScanner 

pub struct WalScanner { /* private fields */ }

Follows the chain through one segment from a growing prefix of its bytes, like crate::segment::SegmentScanner.

Implementations

impl WalScanner

pub fn start(bytes: &[u8], complete: bool) -> Result<Option<Self>, WalError>

Starts at the segment’s base. expect is the chain position the previous segment ended at (None for the first segment read, which must start at or before the position recovery needs). Ok(None) for a never-activated segment.

pub fn header(&self) -> &WalHeader

pub fn advance( &mut self, bytes: &[u8], complete: bool, segment_len: usize, visit: &mut dyn FnMut(&BatchView<'_>), ) -> Progress

Continues over bytes, the segment’s first bytes.len() bytes; segment_len is the file’s length (batches never extend past it). Accepted batches are visited once each, in order.