Struct TxnManager 

pub struct TxnManager { /* private fields */ }

Transaction manager

Manages transaction lifecycle and MVCC timestamps.

Implementations

impl TxnManager

pub fn new() -> Self

Create a new transaction manager

pub fn with_timeout(timeout: Duration) -> Self

Create with custom timeout

pub fn begin(&self) -> TransactionId

Begin a new transaction with default isolation

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

Begin a new transaction with specific isolation level

pub fn commit(&self, txn_id: TransactionId) -> KernelResult<Timestamp>

Commit a transaction

pub fn abort(&self, txn_id: TransactionId) -> KernelResult<()>

Abort a transaction

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

Check if a transaction is active

pub fn snapshot_ts(&self, txn_id: TransactionId) -> KernelResult<Timestamp>

Get snapshot timestamp for a transaction

pub fn record_read(&self, txn_id: TransactionId, table_id: u32, row_id: u64)

Record a read operation (for SSI)

pub fn record_write(&self, txn_id: TransactionId, table_id: u32, row_id: u64)

Record a write operation

pub fn set_last_lsn(&self, txn_id: TransactionId, lsn: LogSequenceNumber)

Update last LSN for a transaction

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

Get minimum active snapshot timestamp (for GC)

pub fn active_count(&self) -> usize

Get active transaction count

pub fn cleanup(&self, retention: Duration)

Clean up completed transactions older than retention period

pub fn check_timeouts(&self) -> Vec<TransactionId>

Check for transactions that have timed out

pub fn current_timestamp(&self) -> Timestamp

Get current timestamp

pub fn restore(&self, next_txn_id: TransactionId, current_ts: Timestamp)

Restore state after recovery

Trait Implementations

impl Default for TxnManager

fn default() -> Self

Returns the “default value” for a type.