Struct WalReader 

pub struct WalReader { /* private fields */ }

Reads and parses a WAL file into a list of events.

Malformed lines are silently skipped. This is intentional — partial writes from crashes may leave incomplete JSON at the end of the file.

Example

use runtimo_core::WalReader;
use std::path::Path;

let reader = WalReader::load(Path::new("/tmp/app.wal")).unwrap();
for event in reader.events() {
    println!("Event: {:?} for job {}", event.event_type, event.job_id);
}

Implementations

impl WalReader

pub fn load(path: &Path) -> Result<Self>

Loads and parses all events from a WAL file.

Errors

Returns Error::WalError if the file cannot be read. Individual malformed lines are skipped, not treated as errors.

pub fn events(&self) -> &[WalEvent]

Returns a slice of all parsed events.

pub fn tail(path: &Path, n: usize) -> Result<Self>

Reads only the last n lines from the WAL file.

More efficient than WalReader::load when only recent events are needed. Malformed lines are silently skipped.

Errors

Returns Error::WalError if the file cannot be read.