Enum potatonet_node::bus_message::Message

pub enum Message {
    Ping,
    RegisterNode(String),
    NodeRegistered(NodeId),
    UnregisterNode,
    RegisterService {
        name: String,
        id: LocalServiceId,
    },
    UnregisterService {
        id: LocalServiceId,
    },
    Req {
        seq: u32,
        from: Option<LocalServiceId>,
        to_service: String,
        method: String,
        data: Bytes,
    },
    XReq {
        from: Option<ServiceId>,
        to: LocalServiceId,
        seq: u32,
        method: String,
        data: Bytes,
    },
    Rep {
        seq: u32,
        result: Result<Bytes, String>,
    },
    SendNotify {
        from: Option<LocalServiceId>,
        to_service: String,
        method: String,
        data: Bytes,
    },
    Notify {
        from: Option<ServiceId>,
        to_service: String,
        method: String,
        data: Bytes,
    },
    Event {
        event: Event,
    },
}

Variants

Ping

客户端发送ping

RegisterNode(String)

客户端注册节点

NodeRegistered(NodeId)

服务端发送节点注册成功消息，并返回节点id

UnregisterNode

客户端退出

RegisterService

注册服务

Fields of RegisterService

name: Stringid: LocalServiceId

UnregisterService

注销服务

Fields of UnregisterService

id: LocalServiceId

Req

客户端发送请求

Fields of Req

seq: u32from: Option<LocalServiceId>to_service: Stringmethod: Stringdata: Bytes

XReq

服务端发送请求

Fields of XReq

from: Option<ServiceId>to: LocalServiceIdseq: u32method: Stringdata: Bytes

Rep

服务端发送响应

Fields of Rep

seq: u32result: Result<Bytes, String>

SendNotify

客户端发送通知

Fields of SendNotify

from: Option<LocalServiceId>to_service: Stringmethod: Stringdata: Bytes

Notify

服务端发送通知

Fields of Notify

from: Option<ServiceId>to_service: Stringmethod: Stringdata: Bytes

Event

系统事件

Fields of Event

event: Event

Trait Implementations

impl Debug for Message

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Message

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

Deserialize this value from the given Serde deserializer.

impl Serialize for Message

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.