Struct ConcurrentBatchedWal 

pub struct ConcurrentBatchedWal { /* private fields */ }

Thread-safe batched WAL writer

Wraps BatchedWalWriter with a mutex for concurrent access.

Implementations

impl ConcurrentBatchedWal

pub fn new<P: AsRef<Path>>(path: P) -> Result<Self>

Create a new concurrent batched WAL

pub fn begin(&self) -> BatchAccumulator

Begin a new transaction batch

pub fn commit(&self, batch: BatchAccumulator) -> Result<usize>

Commit a transaction batch

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

Append a single entry

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

Force flush

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

Force sync

pub fn stats(&self) -> BatchedWalStats

Get statistics