Struct TransactionManager 

pub struct TransactionManager { /* private fields */ }

Transaction manager

Implementations

impl TransactionManager

pub fn new(config: TxnConfig) -> Self

Create new transaction manager

pub fn with_default_config() -> Self

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<Self>) -> Transaction

Begin with Transaction wrapper

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

Record a read operation

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

Record a write operation

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

Acquire lock for key

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

Commit transaction

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

Abort transaction

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

Create savepoint

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

Rollback to savepoint

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

Get transaction state

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

Check if transaction is active

pub fn active_count(&self) -> usize

Get active transaction count

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

Get oldest active transaction timestamp

pub fn cleanup(&self, max_age: Duration)

Cleanup finished transactions

Trait Implementations

impl Default for TransactionManager

fn default() -> Self

Returns the “default value” for a type.