Struct WalReader 

pub struct WalReader { /* private fields */ }

Streaming reader used by recovery. Stops at the first torn record (REC_LEN == 0) or CRC mismatch, returning the cleanly-committed prefix.

Implementations

impl WalReader

pub fn open(path: impl AsRef<Path>) -> Result<Self>

pub fn open_with_cipher( path: impl AsRef<Path>, cipher: Option<Box<dyn Cipher>>, ) -> Result<Self>

Open a WAL segment for reading, optionally with a decryption cipher.

pub fn next_record(&mut self) -> Result<Option<Record>>

Read the next record. Returns Ok(None) at a clean end-of-records (zero-length marker or EOF), and Err(TornWrite) for a partial record.

pub fn replay(&mut self) -> Result<Vec<Record>>

Replay all cleanly-committed records. A torn tail (crash mid-append or a partially-flushed last frame) is treated as end-of-log and truncated — the valid prefix is returned. A CRC failure or short read that is followed by a well-formed frame is treated as interior corruption and surfaces as MongrelError::CorruptWal (spec §8.4, review fix #22).

pub fn current_offset(&self) -> u64

Position the write cursor at end of file (for a reopen-and-append path, to be implemented alongside segment rotation).