Enum CausalMessage 

pub enum CausalMessage<D> {
    DeltaInterval(DeltaInterval<D>),
    Ack(IntervalAck),
    SnapshotRequest {
        from: ReplicaId,
        to: ReplicaId,
    },
    Snapshot {
        from: ReplicaId,
        to: ReplicaId,
        state: D,
        seq: SeqNo,
    },
}

Messages for the causal anti-entropy protocol

Variants

DeltaInterval(DeltaInterval<D>)

Delta-interval with causal ordering information

Ack(IntervalAck)

Acknowledgment of received interval

SnapshotRequest

Request for state snapshot (for bootstrapping new replicas)

Fields

from: ReplicaId

to: ReplicaId

Snapshot

Full state snapshot response

Fields

from: ReplicaId

to: ReplicaId

state: D

seq: SeqNo

Trait Implementations

impl<D: Clone> Clone for CausalMessage<D>

fn clone(&self) -> CausalMessage<D>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<D: Debug> Debug for CausalMessage<D>

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

Formats the value using the given formatter.