Function replay_all_segments

nodedb-wal/src/segmented.rs:289–301

Replay all records from all segments in a WAL directory, in LSN order. Segments are read in order of their first_lsn. Within each segment, records are read sequentially. This produces a globally ordered stream.

(wal_dir: &Path)

/// Segments are read in order of their first_lsn. Within each segment,
/// records are read sequentially. This produces a globally ordered stream.
pub fn replay_all_segments(wal_dir: &Path) -> Result<Vec<WalRecord>> {
    let segments = discover_segments(wal_dir)?;
    let mut all_records = Vec::new();

    for seg in &segments {
        let reader = crate::reader::WalReader::open(&seg.path)?;
        for record_result in reader.records() {
            all_records.push(record_result?);
        }
    }

    Ok(all_records)
}

/// Paginated replay from a WAL directory: reads at most `max_records` from `from_lsn`.
///