Struct TransactionLog 

pub struct TransactionLog { /* private fields */ }

Durable transaction log for the coordinator

Stores coordinator decisions to enable crash recovery with presumed abort semantics.

Implementations

impl TransactionLog

pub fn new() -> Self

Create a new transaction log

pub fn log_decision( &mut self, tx_id: &TransactionId, decision: CoordinatorDecision, participants: &[String], )

Log a coordinator decision

pub fn update_decision( &mut self, tx_id: &TransactionId, decision: CoordinatorDecision, )

Update an existing decision

pub fn get_decision(&self, tx_id: &TransactionId) -> Option<CoordinatorDecision>

Get the decision for a transaction

pub fn get_entry(&self, tx_id: &TransactionId) -> Option<&TransactionLogEntry>

Get an entry by transaction ID

pub fn entries(&self) -> &[TransactionLogEntry]

Get all entries

pub fn get_pending_for_recovery( &self, ) -> (Vec<&TransactionLogEntry>, Vec<&TransactionLogEntry>)

Get transactions that need recovery action.

Returns a tuple of committed and to-abort entries:

• Committed: need to re-send commit
• To abort: were in PREPARING state (presumed abort)

pub fn prune_completed(&mut self, tx_ids: &[TransactionId])

Remove completed transactions from the log

pub fn to_bytes(&self) -> Vec<u8>

Serialize the entire log to bytes

pub fn from_bytes(bytes: &[u8]) -> Result<Self, SinkError>

Deserialize from bytes

Errors

Returns an error if the bytes are malformed.

Trait Implementations

impl Debug for TransactionLog

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

Formats the value using the given formatter.

impl Default for TransactionLog

fn default() -> Self

Returns the “default value” for a type.