Struct BatchAccumulator 

pub struct BatchAccumulator { /* private fields */ }

Batch entry accumulator for a single transaction

Collects all writes for a transaction and commits them as a single batch.

Implementations

impl BatchAccumulator

pub fn new(txn_id: u64) -> Self

Create a new batch accumulator for a transaction

pub fn write(&mut self, key: Vec<u8>, value: Vec<u8>)

Add a write to the batch (does not hit WAL yet)

pub fn delete(&mut self, key: Vec<u8>)

Add a delete to the batch

pub fn len(&self) -> usize

Get entry count

pub fn is_empty(&self) -> bool

Check if empty

pub fn commit(self, writer: &mut BatchedWalWriter) -> Result<usize>

Commit batch - writes all entries to WAL in single batch

Arguments

• writer - Batched WAL writer

Returns

The number of entries written

pub fn abort(self)

Abort the batch (discard all pending writes)

pub fn txn_id(&self) -> u64

Get the transaction ID