Enum Inbound 

pub enum Inbound {
    Heartbeat {
        from: NodeId,
        msg: SyncHeartbeat,
    },
    SyncRequest {
        from: NodeId,
        msg: SyncRequest,
    },
    SyncResponse {
        from: NodeId,
        msg: SyncResponse,
    },
    SyncNack {
        from: NodeId,
        msg: SyncNack,
    },
    Shutdown,
}

Inbound event the runtime processes. The mesh-side dispatcher pushes one of these into the runtime’s inbox per inbound wire frame; the runtime’s task drains the receiver on every wakeup.

Variants

Heartbeat

Peer’s heartbeat — record into the tracker.

Fields

from: NodeId

Originating node id.

msg: SyncHeartbeat

Wire-format heartbeat payload.

SyncRequest

Peer (replica) asked us (leader) for events. Run handle_sync_request against the local file + dispatch the response or nack.

Fields

from: NodeId

Originating replica.

msg: SyncRequest

Wire-format request.

SyncResponse

Peer (leader) shipped us a chunk. Apply via apply_sync_response; on success advance our tail.

Fields

from: NodeId

Originating leader.

msg: SyncResponse

Wire-format response.

SyncNack

Peer (leader) rejected our request with a typed error.

Fields

from: NodeId

Originating leader.

msg: SyncNack

Wire-format nack.

Shutdown

Shutdown signal from Redex::open_file cleanup or from channel-close. Drives coordinator.transition_to(Idle, ChannelClose) and exits the task loop.

Trait Implementations

impl Clone for Inbound

fn clone(&self) -> Inbound

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Inbound

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

Formats the value using the given formatter.