Struct SyncMessage 

pub struct SyncMessage {
    pub batch_id: String,
    pub source_node_id: NodeId,
    pub sequence_start: u64,
    pub sequence_end: u64,
    pub event_count: usize,
    pub events_hash: String,
    pub created_at_ms: u64,
    pub previous_batch_hash: Option<String>,
    pub events: Vec<Vec<u8>>,
}

Mensagem de replicação enviada do líder para o seguidor.

Fields

batch_id: String

Idempotency identifier for this replication batch.

source_node_id: NodeId

Node that produced the batch.

sequence_start: u64

Inclusive sequence of the first event in the batch.

sequence_end: u64

Inclusive sequence of the final event in the batch.

event_count: usize

Declared event count, validated against events.

events_hash: String

SHA-256 integrity hash over metadata and event bytes.

created_at_ms: u64

Batch creation time in Unix epoch milliseconds.

previous_batch_hash: Option<String>

Hash of the preceding accepted batch, when one exists.

events: Vec<Vec<u8>>

Opaque serialized event payloads in sequence order.

Implementations

impl SyncMessage

pub fn new( batch_id: String, source_node_id: NodeId, sequence_start: u64, sequence_end: u64, created_at_ms: u64, previous_batch_hash: Option<String>, events: Vec<Vec<u8>>, ) -> Self

Builds a batch and computes its count and integrity hash.

pub fn new_simple( source_node_id: NodeId, sequence: u64, events: Vec<Vec<u8>>, ) -> Self

Builds an unchained batch with a deterministic identifier and zero timestamp.

Trait Implementations

impl Clone for SyncMessage

fn clone(&self) -> SyncMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SyncMessage

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SyncMessage

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for SyncMessage

impl PartialEq for SyncMessage

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for SyncMessage

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for SyncMessage