Struct TransactionManager 

pub struct TransactionManager { /* private fields */ }

Transaction Manager

Coordinates transactions and manages the WAL.

Implementations

impl TransactionManager

pub fn new(pager: Arc<Pager>, wal_path: impl AsRef<Path>) -> Result<Self>

Create a new transaction manager

Arguments

• pager - The pager to use for page I/O
• wal_path - Path to the WAL file

pub fn begin(self: &Arc<Self>) -> Result<Transaction, TxError>

Begin a new transaction

pub fn active_transactions(&self) -> Vec<u64>

Get list of active transaction IDs

pub fn wal_path(&self) -> &Path

Get WAL file path

pub fn pager(&self) -> &Arc<Pager>

Get reference to pager

pub fn sync_wal(&self) -> Result<()>

Sync WAL to disk. Drains every byte that has been reserved via the coordinator — i.e. waits until the coordinator’s next_lsn is durable.

pub fn has_active_transactions(&self) -> bool

Check if there are active transactions