Struct WalManager 

pub struct WalManager { /* private fields */ }

Manages the Write-Ahead Log.

Implementations

impl WalManager

pub fn new(storage: Arc<dyn Storage>, path: &str) -> Result<Self>

Create a new WAL manager.

pub fn set_next_seq(&self, seq: SeqNumber)

Set the next sequence number (e.g. after loading snapshot).

pub fn last_seq(&self) -> SeqNumber

Get the last used sequence number.

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

Append an entry to the WAL. Returns the assigned sequence number.

pub fn read_all(&self) -> Result<Vec<WalRecord>>

Read all entries from the WAL. Also updates the internal next_seq to max_seq + 1.

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

Truncate (clear) the WAL. This is typically called after a successful flush/checkpoint.

Trait Implementations

impl Debug for WalManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.