Enum SyncPayload 

pub enum SyncPayload {
    Hello(PeerInfo),
    ClockRequest,
    ClockResponse(VectorClock),
    DeltaRequest {
        since_clock: VectorClock,
    },
    DeltaResponse {
        deltas: DeltaBatch,
        has_more: bool,
    },
    FullState {
        state: GA3,
        clock: VectorClock,
    },
    Heartbeat,
    Ack {
        message_id: u64,
        applied_clock: VectorClock,
    },
    Goodbye,
}

The payload of a sync message.

Variants

Hello(PeerInfo)

Announce presence to peers

ClockRequest

Request clock comparison

ClockResponse(VectorClock)

Response with current clock

DeltaRequest

Request deltas since a given clock

Fields

since_clock: VectorClock

The clock the requester has

DeltaResponse

Response with deltas

Fields

deltas: DeltaBatch

Deltas to apply

has_more: bool

Whether more deltas are available

FullState

Full state sync (for new peers or recovery)

Fields

state: GA3

The complete state

clock: VectorClock

Clock at this state

Heartbeat

Heartbeat to maintain connection

Ack

Acknowledge receipt of deltas

Fields

message_id: u64

Message ID being acknowledged

applied_clock: VectorClock

Applied clock

Goodbye

Goodbye message when leaving

Trait Implementations

impl Clone for SyncPayload

fn clone(&self) -> SyncPayload

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SyncPayload

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SyncPayload

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for SyncPayload

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

where __S: Serializer,

Serialize this value into the given Serde serializer.