Struct TransactionLog 

pub struct TransactionLog { /* private fields */ }

Transaction Log (WAL)

Implementations

impl TransactionLog

pub fn new(config: WalConfig) -> Result<TransactionLog, Error>

Create new transaction log

pub fn in_memory() -> TransactionLog

Create in-memory log (no persistence)

pub fn append(&self, entry: LogEntry) -> Result<u64, Error>

Append entry to log

pub fn log_begin(&self, txn_id: u64) -> Result<u64, Error>

Log transaction begin

pub fn log_commit(&self, txn_id: u64) -> Result<u64, Error>

Log transaction commit

pub fn log_abort(&self, txn_id: u64) -> Result<u64, Error>

Log transaction abort

pub fn log_insert( &self, txn_id: u64, key: Vec<u8>, value: Vec<u8>, ) -> Result<u64, Error>

Log insert operation

pub fn log_update( &self, txn_id: u64, key: Vec<u8>, old_value: Vec<u8>, new_value: Vec<u8>, ) -> Result<u64, Error>

Log update operation

pub fn log_delete( &self, txn_id: u64, key: Vec<u8>, old_value: Vec<u8>, ) -> Result<u64, Error>

Log delete operation

pub fn log_savepoint(&self, txn_id: u64, name: String) -> Result<u64, Error>

Log savepoint

pub fn checkpoint(&self, active_txns: Vec<u64>) -> Result<u64, Error>

Write checkpoint

pub fn flush(&self) -> Result<(), Error>

Flush buffer to disk

pub fn get_txn_entries(&self, txn_id: u64) -> Vec<LogEntry>

Get entries for a transaction (for undo)

pub fn get_entries_since(&self, lsn: u64) -> Vec<LogEntry>

Get entries since LSN

pub fn current_lsn(&self) -> u64

Get current LSN

pub fn last_checkpoint(&self) -> u64

Get last checkpoint LSN

pub fn stats(&self) -> WalStats

Get statistics

pub fn config(&self) -> &WalConfig

Get configuration