Struct rpcx_protocol::message::Message

pub struct Message {
    pub header: [u8; 12],
    pub service_path: String,
    pub service_method: String,
    pub metadata: RefCell<Metadata>,
    pub payload: Vec<u8>,
}

a commmon struct for request and response.

Fields

header: [u8; 12]

service_path: String

service_method: String

metadata: RefCell<Metadata>

payload: Vec<u8>

Methods

impl Message

pub fn new() -> Self

Creates a new Message

pub fn get_reply(&self) -> Result<Self>

Trait Implementations

impl RpcxMessage for Message

fn check_magic_number(&self) -> bool

fn get_version(&self) -> u8

fn set_version(&mut self, v: u8)

fn get_message_type(&self) -> Option<MessageType>

fn set_message_type(&mut self, mt: MessageType)

fn is_heartbeat(&self) -> bool

fn set_heartbeat(&mut self, b: bool)

fn is_oneway(&self) -> bool

fn set_oneway(&mut self, b: bool)

fn get_compress_type(&self) -> Option<CompressType>

fn set_compress_type(&mut self, ct: CompressType)

fn get_message_status_type(&self) -> Option<MessageStatusType>

fn set_message_status_type(&mut self, mst: MessageStatusType)

fn get_serialize_type(&self) -> Option<SerializeType>

fn set_serialize_type(&mut self, st: SerializeType)

fn get_seq(&self) -> u64

fn set_seq(&mut self, seq: u64)

fn decode<R: ?Sized>(&mut self, r: &mut R) -> Result<()> where
    R: Read, 

fn encode(&self) -> Vec<u8>

fn get_error(&self) -> Option<String>

impl Default for Message

fn default() -> Message

Returns the "default value" for a type.

impl Debug for Message

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

Formats the value using the given formatter.