Struct Wal 

pub struct Wal { /* private fields */ }

Write-Ahead Log manager

Implementations

impl Wal

pub fn new(path: impl AsRef<Path>) -> Result<Wal, WalError>

Create a new WAL

pub fn set_sync_mode(&mut self, sync: bool)

Set sync mode

pub fn current_sequence(&self) -> u64

Get current sequence number

Returns the current WAL sequence number which increments with each write. This is needed by PersistenceManager::checkpoint() to record the actual checkpoint sequence instead of always using 0, which was causing misleading output in the banking demo (WAL checkpoint always showed sequence 0).

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

Append an entry to the WAL

pub fn flush(&mut self) -> Result<(), WalError>

Force flush the WAL

pub fn replay<F>( &self, from_sequence: u64, callback: F, ) -> Result<u64, WalError>

where F: FnMut(&WalEntry) -> Result<(), WalError>,

Replay the WAL from a specific sequence number

pub fn checkpoint(&mut self, sequence: u64) -> Result<(), WalError>

Create a checkpoint and truncate old WAL entries