Struct WalRing 

pub struct WalRing { /* private fields */ }

Ring buffer WAL

Implementations

impl WalRing

pub fn create(path: impl AsRef<Path>, region: Region) -> Result<Self>

Create a new ring buffer WAL

pub fn open(path: impl AsRef<Path>, region: Region) -> Result<Self>

Open existing ring buffer WAL and recover

pub fn append(&self, record: Record) -> Result<Lsn>

Append a record to the WAL (buffered)

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

Flush pending records to disk (group commit)

pub fn read_all(&self) -> Result<Vec<(Lsn, Record)>>

Read all records from WAL

pub fn set_checkpoint(&self, lsn: Lsn) -> Result<()>

Set checkpoint LSN (for compaction)

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

Compact WAL by removing entries before checkpoint Note: In a ring buffer, this just means we can overwrite them on next wrap

pub fn next_lsn(&self) -> Lsn

Get next LSN

pub fn set_batch_timeout(&self, timeout: Duration)

Set batch timeout for group commit