Struct TransactionRecord 

pub struct TransactionRecord {
    pub tx_id: TransactionId,
    pub decision: CoordinatorDecision,
    pub participants: HashMap<String, ParticipantState>,
    pub started_at: Instant,
    pub decision_at: Option<Instant>,
}

Transaction state in the coordinator

Fields

tx_id: TransactionId

Transaction ID

decision: CoordinatorDecision

Current decision

participants: HashMap<String, ParticipantState>

Participant states

started_at: Instant

Transaction start time

decision_at: Option<Instant>

When decision was made

Implementations

impl TransactionRecord

pub fn new(tx_id: TransactionId, participant_ids: &[String]) -> Self

Create a new transaction record

pub fn all_voted_yes(&self) -> bool

Check if all participants have voted yes

pub fn any_voted_no_or_timeout(&self) -> bool

Check if any participant voted no or timed out

pub fn all_acknowledged(&self) -> bool

Check if all participants have acknowledged

pub fn pending_voters(&self) -> Vec<&str>

Get participants that haven’t voted yet

pub fn pending_acknowledgments(&self) -> Vec<&str>

Get participants that haven’t acknowledged yet

pub fn make_decision(&mut self, decision: CoordinatorDecision)

Mark decision and timestamp

Trait Implementations

impl Clone for TransactionRecord

fn clone(&self) -> TransactionRecord

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TransactionRecord

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

Formats the value using the given formatter.