Struct TransactionJournal 

pub struct TransactionJournal { /* private fields */ }

Transaction Journal Manager

Implementations

impl TransactionJournal

pub fn new() -> Self

Create a new transaction journal manager

pub fn with_max_entries(self, max: usize) -> Self

Configure maximum entries

pub fn with_max_size(self, max: usize) -> Self

Configure maximum size

pub fn set_enabled(&mut self, enabled: bool)

Enable or disable journaling

pub async fn entries_in_window( &self, from: DateTime<Utc>, to: DateTime<Utc>, ) -> Vec<(Uuid, JournalEntry)>

Collect every journal entry across every active transaction whose timestamp falls within the inclusive window [from, to]. Results are sorted in timestamp order so the caller can replay them chronologically regardless of which transaction they came from.

Used by the time-travel replay engine (src/replay/) to reconstruct “what happened at the source between these two timestamps” against a staging target.

pub async fn begin_transaction( &self, tx_id: Uuid, session_id: Uuid, node_id: NodeId, start_lsn: u64, ) -> Result<()>

Start journaling a transaction

pub async fn log_statement( &self, tx_id: Uuid, statement: String, parameters: Vec<JournalValue>, result_checksum: Option<u64>, rows_affected: Option<u64>, duration_ms: u64, ) -> Result<()>

Log a statement

pub async fn create_savepoint(&self, tx_id: Uuid, name: String) -> Result<()>

Create a savepoint

pub async fn rollback_to_savepoint(&self, tx_id: Uuid, name: &str) -> Result<()>

Rollback to savepoint

pub async fn commit_transaction(&self, tx_id: Uuid) -> Result<()>

Commit transaction (clear journal)

pub async fn rollback_transaction(&self, tx_id: Uuid) -> Result<()>

Rollback transaction (clear journal)

pub async fn get_journal(&self, tx_id: &Uuid) -> Option<TransactionJournalEntry>

Get journal for a transaction (for replay)

pub async fn active_count(&self) -> usize

Get active transaction count

pub async fn stats(&self) -> JournalStats

Get statistics

pub async fn get_all_active(&self) -> Vec<TransactionJournalEntry>

Get all active transaction journals (for failover replay)

pub async fn get_max_start_lsn(&self) -> Option<u64>

Get the maximum start LSN across all active transactions Used to determine how far the standby needs to catch up

pub async fn get_transactions_for_node( &self, node_id: NodeId, ) -> Vec<TransactionJournalEntry>

Get transactions that started on a specific node Useful for replaying only transactions affected by a node failure

Trait Implementations

impl Default for TransactionJournal

fn default() -> Self

Returns the “default value” for a type.