Enum Frame 

pub enum Frame {
    Ping {
        seq: u64,
        from: NodeId,
    },
    Ack {
        seq: u64,
        from: NodeId,
    },
    PingReq {
        seq: u64,
        from: NodeId,
        target: NodeId,
    },
    Gossip(GossipMessage),
    User(UserMessage),
    Raft(RaftFrame),
    RaftSnapshot(RaftFrame),
    FileTransfer(FileTransferFrame),
}

A frame is the unit of communication between nodes.

Variants

Ping

Fields

seq: u64

from: NodeId

Ack

Fields

seq: u64

from: NodeId

PingReq

Fields

seq: u64

from: NodeId

target: NodeId

Gossip(GossipMessage)

User(UserMessage)

Raft(RaftFrame)

Raft RPC用の汎用フレーム。payloadは上位層でbincodeシリアライズされたRPCを格納する。

RaftSnapshot(RaftFrame)

スナップショット転送専用フレーム。

FileTransfer(FileTransferFrame)

ファイル転送制御フレーム。

Trait Implementations

impl Clone for Frame

fn clone(&self) -> Frame

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Frame

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Frame

fn deserialize<__D>( __deserializer: __D, ) -> Result<Frame, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Frame

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.