Struct TransactionManager 

pub struct TransactionManager { /* private fields */ }

Manages all active transactions.

Implementations

impl TransactionManager

pub fn new() -> Self

pub fn begin(&self, isolation_level: IsolationLevel) -> Result<TransactionId>

Begin a new transaction.

pub fn commit(&self, tx_id: TransactionId) -> Result<()>

Commit a transaction.

pub fn abort(&self, tx_id: TransactionId) -> Result<()>

Abort a transaction.

pub fn read( &self, tx_id: TransactionId, key: &VersionKey, ) -> Result<Option<Vec<u8>>>

Read a version visible to the transaction.

pub fn write( &self, tx_id: TransactionId, key: VersionKey, data: Vec<u8>, ) -> Result<()>

Write a new version.

pub fn delete(&self, tx_id: TransactionId, key: &VersionKey) -> Result<()>

Delete a version.

pub fn stats(&self) -> TransactionStats

Get transaction statistics.

pub fn run_gc(&self) -> GcStats

Run garbage collection to remove old versions that are no longer visible. Returns the number of versions collected.

pub fn run_gc_if_needed(&self, threshold: usize) -> Option<GcStats>

Run garbage collection with a threshold. Only runs if there are more than threshold versions.

Trait Implementations

impl Default for TransactionManager

fn default() -> Self

Returns the “default value” for a type.