Struct WriteAheadLog 

pub struct WriteAheadLog { /* private fields */ }

Write-Ahead Log for durability and crash recovery

Implementations

impl WriteAheadLog

pub fn new(wal_dir: impl Into<PathBuf>, config: WALConfig) -> Result<Self>

Create a new WAL

pub fn append(&self, event: Event) -> Result<u64>

Write an event to the WAL

pub fn recover(&self) -> Result<Vec<Event>>

Recover events from WAL files

pub fn flush(&self) -> Result<()>

Manually flush the current WAL file

pub fn sync(&self) -> Result<()>

Flush the BufWriter and fsync the current WAL file to disk.

Called by the background interval-based fsync task. Acquires the write lock, flushes buffered data, then issues sync_all() to ensure the OS has persisted the data to durable storage.

pub fn fsync_interval_ms(&self) -> Option<u64>

Get the configured fsync interval (if any).

pub fn truncate(&self) -> Result<()>

Truncate WAL after successful checkpoint

pub fn stats(&self) -> WALStats

Get WAL statistics

pub fn current_sequence(&self) -> u64

Get current sequence number

pub fn oldest_sequence(&self) -> Option<u64>

Get the oldest available WAL sequence number.

Returns the first sequence found in the oldest WAL file, or None if no WAL entries exist. Used by the replication catch-up protocol to determine whether a follower can catch up from WAL alone.

pub fn set_replication_tx(&self, tx: Sender<WALEntry>)

Attach a broadcast sender for WAL replication.

When set, every append() call will publish the WAL entry to this channel so the WAL shipper can stream it to connected followers.