pub trait RpcxMessage {
Show 20 methods
// 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 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>(&mut self, r: &mut R) -> Result<()>
where R: Read + ?Sized;
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 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>(&mut self, r: &mut R) -> Result<()>
fn encode(&self) -> Vec<u8> ⓘ
fn get_error(&self) -> Option<String>
Dyn Compatibility§
This trait is not dyn compatible.
In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.