Enum GossipMessage 

pub enum GossipMessage {
    Ping {
        seq: u64,
        sender: NodeId,
        updates: Vec<NodeUpdate>,
    },
    PingReq {
        seq: u64,
        sender: NodeId,
        target: NodeId,
        target_addr: SocketAddr,
    },
    Ack {
        seq: u64,
        sender: NodeId,
        updates: Vec<NodeUpdate>,
    },
    Join {
        sender: NodeId,
        sender_addr: SocketAddr,
    },
    Welcome {
        sender: NodeId,
        members: Vec<MemberInfo>,
    },
}

Message types for the SWIM gossip protocol.

Variants

Ping

Direct probe to check if a node is alive.

Fields

seq: u64

sender: NodeId

updates: Vec<NodeUpdate>

Piggybacked state updates.

PingReq

Request another node to probe a target on our behalf.

Fields

seq: u64

sender: NodeId

target: NodeId

target_addr: SocketAddr

Ack

Response to a Ping or forwarded PingReq.

Fields

seq: u64

sender: NodeId

updates: Vec<NodeUpdate>

Piggybacked state updates.

Join

Join request from a new node.

Fields

sender: NodeId

sender_addr: SocketAddr

Welcome

Welcome response with current cluster state.

Fields

sender: NodeId

members: Vec<MemberInfo>

Implementations

impl GossipMessage

pub fn encode(&self) -> Bytes

Serializes the message to bytes.

pub fn encode_into(&self, buf: &mut BytesMut)

Serializes the message into the given buffer.

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

Deserializes a message from bytes.

Trait Implementations

impl Clone for GossipMessage

fn clone(&self) -> GossipMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for GossipMessage

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

Formats the value using the given formatter.

impl PartialEq for GossipMessage

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