Struct TransactionJournalEntry 

pub struct TransactionJournalEntry {
    pub tx_id: Uuid,
    pub session_id: Uuid,
    pub node_id: NodeId,
    pub started_at: DateTime<Utc>,
    pub start_lsn: u64,
    pub entries: Vec<JournalEntry>,
    pub current_sequence: u64,
    pub active: bool,
    pub has_mutations: bool,
    pub savepoints: Vec<Savepoint>,
}

Transaction journal for a single transaction

Fields

tx_id: Uuid

Transaction ID

session_id: Uuid

Session ID

node_id: NodeId

Node where transaction started

started_at: DateTime<Utc>

Transaction start time

start_lsn: u64

Start LSN (for WAL synchronization)

entries: Vec<JournalEntry>

Journal entries

current_sequence: u64

Current sequence

active: bool

Is transaction active

has_mutations: bool

Has mutations

savepoints: Vec<Savepoint>

Savepoints

Implementations

impl TransactionJournalEntry

pub fn new( tx_id: Uuid, session_id: Uuid, node_id: NodeId, start_lsn: u64, ) -> Self

Create a new transaction journal entry

pub fn add_entry(&mut self, entry: JournalEntry)

Add an entry to the journal

pub fn create_savepoint(&mut self, name: String)

Create a savepoint

pub fn rollback_to_savepoint(&mut self, name: &str) -> Option<u64>

Rollback to savepoint

pub fn entries_for_replay(&self) -> Vec<&JournalEntry>

Get entries for replay

pub fn mutation_entries(&self) -> Vec<&JournalEntry>

Get only mutation entries

pub fn total_size(&self) -> usize

Calculate total size of journal

Trait Implementations

impl Clone for TransactionJournalEntry

fn clone(&self) -> TransactionJournalEntry

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for TransactionJournalEntry

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.