Enum OutboundMessage 

pub enum OutboundMessage {
    Heartbeat {
        target: NodeId,
        msg: SyncHeartbeat,
    },
    SyncRequest {
        target: NodeId,
        msg: SyncRequest,
    },
}

Outbound wire message the runtime layer ships. The runtime routes by target — every variant identifies the destination node id.

Variants

Heartbeat

Periodic liveness + tail-seq heartbeat. Emitted to every replica in the channel’s replica set on every tick.

Fields

target: NodeId

Destination node id.

msg: SyncHeartbeat

Wire-format heartbeat payload.

SyncRequest

Replica → leader pull request. Emitted by tick when the believed leader’s last-observed tail_seq exceeds the local tail_seq (i.e., we’re behind). One request per lagging tick; the leader’s SyncResponse advances the local tail and the next tick re-evaluates lag. Bounded by chunk_max_bytes from TickInputs.

Fields

target: NodeId

Destination leader node id.

msg: SyncRequest

Wire-format request payload.

Trait Implementations

impl Clone for OutboundMessage

fn clone(&self) -> OutboundMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OutboundMessage

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

Formats the value using the given formatter.

impl PartialEq for OutboundMessage

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

impl StructuralPartialEq for OutboundMessage