Struct BatchedWalWriter 

pub struct BatchedWalWriter { /* private fields */ }

Batched WAL writer with vectored I/O

Accumulates WAL entries and writes them in batches using writev() for optimal I/O performance.

Implementations

impl BatchedWalWriter

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

Create a new batched WAL writer

Arguments

• path - Path to WAL file

pub fn with_config<P: AsRef<Path>>( path: P, max_batch_size: usize, max_batch_bytes: usize, ) -> Result<Self>

Create with custom configuration

Arguments

• path - Path to WAL file
• max_batch_size - Maximum entries per batch
• max_batch_bytes - Maximum bytes per batch

pub fn from_file(file: File) -> Self

Create from an existing file handle

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

Add entry to pending batch

Entry will be serialized and added to the pending batch. Automatic flush occurs if batch limits are reached.

pub fn append_bytes(&mut self, bytes: Vec<u8>) -> Result<()>

Add pre-serialized entry bytes

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

Flush pending entries with vectored I/O

Returns the number of entries written.

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

Sync to disk (fsync)

pub fn stats(&self) -> BatchedWalStats

Get statistics

pub fn pending_count(&self) -> usize

Get pending entry count

pub fn pending_bytes(&self) -> usize

Get pending bytes

Trait Implementations

impl Drop for BatchedWalWriter

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.