Function replay_segment_lazy

nodedb-wal/src/lazy_reader.rs:178–187

Open a WAL segment for lazy reading and iterate with a callback. Convenience function for single-pass replay: the callback receives each header and decides whether to read or skip the payload.

(path: &Path, mut handler: F)

/// Convenience function for single-pass replay: the callback receives each
/// header and decides whether to read or skip the payload.
pub fn replay_segment_lazy<F>(path: &Path, mut handler: F) -> Result<()>
where
    F: FnMut(&mut LazyWalReader, &RecordHeader) -> Result<()>,
{
    let mut reader = LazyWalReader::open(path)?;
    while let Some(header) = reader.next_header()? {
        handler(&mut reader, &header)?;
    }
    Ok(())
}

/// Replay all WAL segments in a directory with lazy reading.
///