Enum TwoPhaseMessage 

pub enum TwoPhaseMessage {
    PrepareRequest {
        txn_id: TransactionId,
        operations: Vec<TransactionOperation>,
    },
    PrepareResponse {
        txn_id: TransactionId,
        vote: ParticipantVote,
        participant: NodeId,
    },
    CommitRequest {
        txn_id: TransactionId,
    },
    CommitAck {
        txn_id: TransactionId,
        participant: NodeId,
    },
    AbortRequest {
        txn_id: TransactionId,
    },
    AbortAck {
        txn_id: TransactionId,
        participant: NodeId,
    },
    StatusQuery {
        txn_id: TransactionId,
    },
    StatusResponse {
        txn_id: TransactionId,
        state: TransactionState,
    },
}

Messages for 2PC protocol.

Variants

PrepareRequest

Prepare request from coordinator.

Fields

txn_id: TransactionId

operations: Vec<TransactionOperation>

PrepareResponse

Prepare response from participant.

Fields

txn_id: TransactionId

vote: ParticipantVote

participant: NodeId

CommitRequest

Commit request from coordinator.

Fields

txn_id: TransactionId

CommitAck

Commit acknowledgment from participant.

Fields

txn_id: TransactionId

participant: NodeId

AbortRequest

Abort request from coordinator.

Fields

txn_id: TransactionId

AbortAck

Abort acknowledgment from participant.

Fields

txn_id: TransactionId

participant: NodeId

StatusQuery

Query transaction status (for recovery).

Fields

txn_id: TransactionId

StatusResponse

Status response.

Fields

txn_id: TransactionId

state: TransactionState

Trait Implementations

impl Clone for TwoPhaseMessage

fn clone(&self) -> TwoPhaseMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TwoPhaseMessage

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for TwoPhaseMessage

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for TwoPhaseMessage

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.