Struct WriteAheadLog 

pub struct WriteAheadLog { /* private fields */ }

Write-Ahead Log manager

Implementations

impl WriteAheadLog

pub fn new(config: WalConfig) -> Result<Self>

Create a new WAL

pub fn append(&self, entry: WalEntry) -> Result<u64>

Append an entry to the WAL

pub fn checkpoint(&self) -> Result<u64>

Write a checkpoint marker

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

Recover entries since last checkpoint

pub fn truncate(&self, up_to_lsn: u64) -> Result<u64>

Truncate WAL up to (and including) the given LSN

pub fn current_lsn(&self) -> u64

Get current LSN

pub fn checkpoint_needed(&self) -> &Notify

Notify handle that fires when pending entries reach checkpoint_threshold. A checkpoint driver awaits checkpoint_needed().notified() to trigger a size-bounded checkpoint between periodic ticks (DAK-7428).

pub fn stats(&self) -> WalStats

Get WAL statistics

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

Flush WAL to disk