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>,
    },
    SlotsAnnounce {
        sender: NodeId,
        incarnation: u64,
        slots: Vec<SlotRange>,
    },
}

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>

SlotsAnnounce

Direct slot announcement: the sender is telling peers its current slot ownership without going through the normal piggybacking mechanism. Used by broadcast_local_slots to eagerly push slot state to all peers.

Fields

sender: NodeId

incarnation: u64

slots: Vec<SlotRange>

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.

pub fn encode_authenticated(&self, secret: &ClusterSecret) -> Bytes

Encodes the message with a trailing HMAC-SHA256 tag.

pub fn decode_authenticated(buf: &[u8], secret: &ClusterSecret) -> Result<Self>

Decodes a message, verifying the trailing HMAC-SHA256 tag first.

Returns an error if the buffer is too short or the tag doesn’t match.

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