Trait rpcx_protocol::message::RpcxMessage[][src]

pub trait RpcxMessage {
Show 20 methods 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>;
}
Expand description

define the rpcx message interface.

Required methods

Implementors