Struct CrossClusterSnapshotEnvelope 

pub struct CrossClusterSnapshotEnvelope {
    pub source_cluster_id: String,
    pub source_database_id: String,
    pub snapshot_lsn: u64,
    pub total_bytes: u64,
    pub total_crc32c: u32,
    pub offset: u64,
    pub data: Vec<u8>,
    pub done: bool,
}

Wire envelope that wraps a cross-cluster snapshot chunk.

Encoded with zerompk (MessagePack) and placed in the data field of the existing nodedb_raft::InstallSnapshotRequest. The in-cluster Raft machinery transfers the bytes unchanged; the mirror receiver unwraps this envelope.

Integrity

total_crc32c is the CRC32C of the entire snapshot payload (concatenation of every chunk’s data in offset order). The source computes it once over the snapshot file and stamps the same value into every envelope of the transfer. The receiver maintains a running CRC32C as chunks arrive and validates it against total_crc32c when done = true; mismatch raises super::super::error::MirrorError::SnapshotCrcMismatch and the partial file is discarded.

Fields

source_cluster_id: String

Cluster-id of the source cluster that produced this snapshot.

source_database_id: String

Database id on the source cluster being mirrored.

snapshot_lsn: u64

WAL LSN at which this snapshot was taken. After the snapshot is fully applied the mirror sets last_applied to this value and begins streaming AppendEntries from snapshot_lsn + 1.

total_bytes: u64

Total snapshot size in bytes (same value in every chunk of the same snapshot transfer).

total_crc32c: u32

CRC32C over the entire snapshot payload (same value in every chunk of the same snapshot transfer). Validated by the receiver on the final chunk.

offset: u64

Byte offset within the snapshot for this chunk.

data: Vec<u8>

Chunk payload bytes.

done: bool

True on the final chunk.

Trait Implementations

impl Clone for CrossClusterSnapshotEnvelope

fn clone(&self) -> CrossClusterSnapshotEnvelope

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CrossClusterSnapshotEnvelope

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for CrossClusterSnapshotEnvelope

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for CrossClusterSnapshotEnvelope

fn eq(&self, other: &CrossClusterSnapshotEnvelope) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for CrossClusterSnapshotEnvelope

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for CrossClusterSnapshotEnvelope

impl StructuralPartialEq for CrossClusterSnapshotEnvelope