Struct TransactionManager 

pub struct TransactionManager<BaseCtx, StagingCtx>
where
    BaseCtx: TransactionContext + 'static,
    StagingCtx: TransactionContext + 'static,
{ /* private fields */ }

Transaction manager for coordinating sessions.

This is the top-level coordinator that creates sessions and manages the shared transaction ID allocator.

Implementations

impl<BaseCtx, StagingCtx> TransactionManager<BaseCtx, StagingCtx>

where BaseCtx: TransactionContext + 'static, StagingCtx: TransactionContext + 'static,

pub fn new() -> TransactionManager<BaseCtx, StagingCtx>

pub fn new_with_initial_txn_id( next_txn_id: u64, ) -> TransactionManager<BaseCtx, StagingCtx>

Create a new TransactionManager with a custom initial transaction ID.

pub fn new_with_initial_state( next_txn_id: u64, last_committed: u64, ) -> TransactionManager<BaseCtx, StagingCtx>

Create a new TransactionManager with custom initial state.

pub fn create_session( &self, context: Arc<BaseCtx>, ) -> TransactionSession<BaseCtx, StagingCtx>

Create a new session for transaction management.

pub fn txn_manager(&self) -> Arc<TxnIdManager>

Obtain the shared transaction ID manager.

pub fn has_active_transaction(&self) -> bool

Check if there’s an active transaction (checks if ANY session has a transaction).

Trait Implementations

impl<BaseCtx, StagingCtx> Default for TransactionManager<BaseCtx, StagingCtx>

where BaseCtx: TransactionContext + 'static, StagingCtx: TransactionContext + 'static,

fn default() -> TransactionManager<BaseCtx, StagingCtx>

Returns the “default value” for a type.