Enum SyncupMsg 

pub enum SyncupMsg {
    EntryRequest {
        vlsn: Vlsn,
    },
    Entry {
        vlsn: Vlsn,
        lsn: u64,
        fingerprint: u64,
        is_sync: bool,
    },
    EntryNotFound,
    AlternateMatchpoint {
        vlsn: Vlsn,
        lsn: u64,
        fingerprint: u64,
        is_sync: bool,
    },
    StartStream {
        start_vlsn: Vlsn,
    },
    RestoreRequest {
        failed_vlsn: Vlsn,
    },
    RestoreResponse,
}

One syncup-protocol message. Wire form: a 1-byte opcode followed by a fixed body (little-endian). Mirrors the BaseProtocol message classes used during syncup.

Variants

EntryRequest

Replica → feeder: “do you have VLSN X (at LSN Y on my side)?” (JE BaseProtocol.EntryRequest). The LSN/fingerprint are the replica’s own values so the feeder need not be asked to compute equality — the replica compares the returned SyncupMsg::Entry.

Fields

vlsn: Vlsn

Entry

Feeder → replica: “here is my record at that VLSN” (JE Entry).

Fields

vlsn: Vlsn

lsn: u64

fingerprint: u64

is_sync: bool

EntryNotFound

Feeder → replica: “I do not hold that VLSN” (below my range) (JE EntryNotFound).

AlternateMatchpoint

Feeder → replica: “that VLSN is above my range; here is my highest sync point as a counter-offer” (JE AlternateMatchpoint).

Fields

vlsn: Vlsn

lsn: u64

fingerprint: u64

is_sync: bool

StartStream

Replica → feeder: “matchpoint agreed; start streaming from this VLSN” (JE StartStream).

Fields

start_vlsn: Vlsn

RestoreRequest

Replica → feeder: “no matchpoint; I need a network restore” (JE RestoreRequest).

Fields

failed_vlsn: Vlsn

RestoreResponse

Feeder → replica: acknowledgement of a restore request (JE RestoreResponse).

Implementations

impl SyncupMsg

pub fn encode(&self) -> Vec<u8>

Serialize to wire bytes.

pub fn decode(buf: &[u8]) -> Result<Self>

Deserialize from wire bytes.

Trait Implementations

impl Clone for SyncupMsg

fn clone(&self) -> SyncupMsg

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SyncupMsg

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

Formats the value using the given formatter.

impl Eq for SyncupMsg

impl PartialEq for SyncupMsg

fn eq(&self, other: &SyncupMsg) -> 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 StructuralPartialEq for SyncupMsg