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
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 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)