Struct ParticipantState 

pub struct ParticipantState {
    pub id: String,
    pub vote: Option<ParticipantVote>,
    pub prepare_sent: bool,
    pub acknowledged: bool,
    pub last_activity: Instant,
}

State of a participant in a transaction

Fields

id: String

Participant identifier

vote: Option<ParticipantVote>

Current vote (if received)

prepare_sent: bool

Whether prepare was sent

acknowledged: bool

Whether commit/abort was acknowledged

last_activity: Instant

Last activity timestamp

Implementations

impl ParticipantState

pub fn new(id: impl Into<String>) -> Self

Create a new participant state

pub fn mark_prepare_sent(&mut self)

Record that prepare was sent

pub fn record_vote(&mut self, vote: ParticipantVote)

Record participant’s vote

pub fn mark_acknowledged(&mut self)

Record acknowledgment

pub fn is_timed_out(&self, timeout: Duration) -> bool

Check if participant has timed out

pub fn voted_yes(&self) -> bool

Check if participant voted yes

pub fn voted_no_or_timeout(&self) -> bool

Check if participant voted no or timed out

Trait Implementations

impl Clone for ParticipantState

fn clone(&self) -> ParticipantState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ParticipantState

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

Formats the value using the given formatter.