crafty-proto 0.2.2

Wire types and postcard codec shared across the crafty framework.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

//! Cross-shard two-phase commit metadata replicated through each Raft group log.

use serde::{Deserialize, Serialize};

/// Prepare staging entry (durable 2PC; not applied to the user state machine).
#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
pub struct TwoPhasePrepareCommand {
    /// Opaque transaction id shared across prepare/commit/abort calls.
    pub tx_id: Vec<u8>,
    /// Shard routing key for this prepare step.
    pub route_key: Vec<u8>,
    /// Application-encoded command staged at prepare time.
    pub command: Vec<u8>,
    /// Unix epoch millis when the prepare was first staged (timeout GC).
    #[serde(default)]
    pub prepared_at_ms: u64,
}

/// Abort/tombstone for a staged prepare (durable 2PC; not applied to the user SM).
#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
pub struct TwoPhaseAbortCommand {
    /// Opaque transaction id.
    pub tx_id: Vec<u8>,
    /// Shard routing key for this prepare step.
    pub route_key: Vec<u8>,
}