Struct TransactionManager 

pub struct TransactionManager { /* private fields */ }

Transaction manager

Implementations

impl TransactionManager

pub fn new(config: TxnConfig) -> TransactionManager

Create new transaction manager

pub fn with_default_config() -> TransactionManager

Create with default config

pub fn config(&self) -> &TxnConfig

Get configuration

pub fn begin(&self) -> TxnHandle

Begin a new transaction

pub fn begin_with_isolation(&self, isolation: IsolationLevel) -> TxnHandle

Begin transaction with specific isolation level

pub fn begin_transaction(self: &Arc<TransactionManager>) -> Transaction

Begin with Transaction wrapper

pub fn record_read(&self, txn_id: u64, key: &[u8], read_ts: u64)

Record a read operation

pub fn record_write( &self, txn_id: u64, key: &[u8], old_value: Option<&[u8]>, new_value: Option<&[u8]>, )

Record a write operation

pub fn acquire_lock( &self, txn_id: u64, key: &[u8], mode: LockMode, ) -> Result<(), TxnError>

Acquire lock for key

pub fn commit(&self, txn_id: u64) -> Result<(), TxnError>

Commit transaction

pub fn abort(&self, txn_id: u64) -> Result<(), TxnError>

Abort transaction

pub fn create_savepoint(&self, txn_id: u64, name: &str) -> Result<(), TxnError>

Create savepoint

pub fn rollback_to_savepoint( &self, txn_id: u64, name: &str, ) -> Result<(), TxnError>

Rollback to savepoint

pub fn get_state(&self, txn_id: u64) -> Option<TxnState>

Get transaction state

pub fn is_active(&self, txn_id: u64) -> bool

Check if transaction is active

pub fn active_count(&self) -> usize

Get active transaction count

pub fn oldest_active_ts(&self) -> Option<u64>

Get oldest active transaction timestamp

pub fn cleanup(&self, max_age: Duration)

Cleanup finished transactions

Trait Implementations

impl Default for TransactionManager

fn default() -> TransactionManager

Returns the “default value” for a type.