Enum PrimaryMessage 

pub enum PrimaryMessage {
    StreamStart {
        start_sequence: u64,
        genesis_entry: Vec<u8>,
    },
    NeedSnapshot,
    HashMismatch,
    SnapshotBegin {
        snapshot_len: u64,
        snap_sequence: u64,
        snap_chain_hash: [u8; 32],
    },
    SnapshotChunk(Vec<u8>),
    SnapshotEnd {
        crc32c: u32,
    },
    Heartbeat {
        sequence: u64,
    },
}

Messages from primary to replica.

Variants

StreamStart

Fields

start_sequence: u64

genesis_entry: Vec<u8>

Primary’s raw genesis entry bytes — the replica writes these directly to its journal for a byte-identical hash chain start.

NeedSnapshot

HashMismatch

SnapshotBegin

Start of a snapshot transfer. Sent after NeedSnapshot.

Fields

snapshot_len: u64

Total snapshot file size in bytes.

snap_sequence: u64

Journal sequence at which the snapshot was taken.

snap_chain_hash: [u8; 32]

BLAKE3 chain hash at the snapshot point.

SnapshotChunk(Vec<u8>)

A chunk of snapshot data. Sent repeatedly after SnapshotBegin.

SnapshotEnd

End of snapshot transfer. Contains CRC32C of the entire snapshot file.

Fields

crc32c: u32

Heartbeat

Fields

sequence: u64

Trait Implementations

impl Debug for PrimaryMessage

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

Formats the value using the given formatter.