Struct RpcMessage 

pub struct RpcMessage {
    pub header: RpcProtocolHeader,
    pub method: Bytes,
    pub body: Bytes,
}

RPC Message

Fields

header: RpcProtocolHeader

method: Bytes

body: Bytes

Implementations

impl RpcMessage

pub fn new_request(sequence: u64, method: Bytes, body: Bytes) -> Self

Create a new request message

pub fn new_response(sequence: u64, body: Bytes) -> Self

Create a new response message

pub fn new_notify(sequence: u64, method: Bytes, body: Bytes) -> Self

Create a new notify message

pub fn new_sysrsp(sequence: u64, body: Bytes) -> Self

Create a new system response message (for error responses when server didn’t finish)

Trait Implementations

impl Clone for RpcMessage

fn clone(&self) -> RpcMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RpcMessage

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

Formats the value using the given formatter.

impl Encoder<RpcMessage> for RpcCodec

type Error = ZusError

The type of encoding errors.

fn encode(&mut self, item: RpcMessage, dst: &mut BytesMut) -> Result<()>

Encodes a frame into the buffer provided.