Struct BatchedTransaction 

pub struct BatchedTransaction<E: StorageEngine> { /* private fields */ }

A transaction that buffers writes for batch commit.

This transaction maintains its own write buffer for isolation - each transaction sees its own uncommitted writes. On commit, all writes are submitted to the batch writer for group commit.

Implementations

impl<E: StorageEngine> BatchedTransaction<E>

pub const fn id(&self) -> u64

Get the transaction ID.

pub fn get( &self, table: &str, key: &[u8], ) -> Result<Option<Vec<u8>>, TransactionError>

Read a value, checking the local buffer first.

This provides read-your-own-writes semantics.

pub fn put( &mut self, table: &str, key: &[u8], value: &[u8], ) -> Result<(), TransactionError>

Buffer a put operation.

pub fn delete( &mut self, table: &str, key: &[u8], ) -> Result<bool, TransactionError>

Buffer a delete operation.

pub fn commit(self) -> Result<(), TransactionError>

Commit the transaction through the batch writer.

This submits all buffered writes to the batch writer for group commit. The method blocks until the batch containing this transaction is committed.

pub fn rollback(self) -> Result<(), TransactionError>

Rollback the transaction, discarding all buffered writes.

pub fn buffered_ops(&self) -> usize

Get the number of buffered operations.

Trait Implementations

impl<E: StorageEngine> Drop for BatchedTransaction<E>

fn drop(&mut self)

Executes the destructor for this type.