Enum PeerMessage 

pub enum PeerMessage {
    Ping {
        node_id: String,
        timestamp: u64,
    },
    Pong {
        node_id: String,
        timestamp: u64,
    },
    RouteRequest {
        request_id: String,
        input: String,
    },
    RouteResponse {
        request_id: String,
        expert_index: usize,
        result: Vec<u8>,
    },
    ShardAssign {
        shard_id: u64,
        node_id: String,
    },
    ShardMigrate {
        shard_id: u64,
        from_node: String,
        to_node: String,
    },
}

Message types for peer communication

Variants

Ping

Heartbeat ping

Fields

node_id: String

timestamp: u64

Pong

Heartbeat pong

Fields

node_id: String

timestamp: u64

RouteRequest

Route request to expert

Fields

request_id: String

input: String

RouteResponse

Route response from expert

Fields

request_id: String

expert_index: usize

result: Vec<u8>

ShardAssign

Shard assignment notification

Fields

shard_id: u64

node_id: String

ShardMigrate

Shard migration request

Fields

shard_id: u64

from_node: String

to_node: String

Implementations

impl PeerMessage

pub fn to_bytes(&self) -> Result<Vec<u8>>

Serialize to bytes

pub fn from_bytes(bytes: &[u8]) -> Result<Self>

Deserialize from bytes

Trait Implementations

impl Clone for PeerMessage

fn clone(&self) -> PeerMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PeerMessage

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for PeerMessage

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for PeerMessage

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

where __S: Serializer,

Serialize this value into the given Serde serializer.