Struct rocketmq_remoting::protocol::remoting_command::RemotingCommand

pub struct RemotingCommand { /* private fields */ }

Implementations

impl RemotingCommand

pub fn create_request_command( code: impl Into<i32>, header: impl CommandCustomHeader + Send + 'static ) -> Self

pub fn create_remoting_command(code: impl Into<i32>) -> Self

pub fn get_and_add() -> i32

pub fn set_cmd_version(self) -> Self

pub fn create_response_command_with_code(code: impl Into<i32>) -> Self

pub fn create_response_command() -> Self

pub fn create_response_command_with_header( header: impl CommandCustomHeader + Send + 'static ) -> Self

pub fn set_command_custom_header( self, command_custom_header: Option<Box<dyn CommandCustomHeader + Send + 'static>> ) -> Self

pub fn set_code(self, code: impl Into<i32>) -> Self

pub fn set_language(self, language: LanguageCode) -> Self

pub fn set_version(&mut self, version: i32)

pub fn set_opaque(self, opaque: i32) -> Self

pub fn set_flag(self, flag: i32) -> Self

pub fn set_remark(self, remark: Option<String>) -> Self

pub fn set_ext_fields(self, ext_fields: HashMap<String, String>) -> Self

pub fn set_body(self, body: Option<impl Into<Bytes>>) -> Self

pub fn set_suspended(self, suspended: bool) -> Self

pub fn set_serialize_type(self, serialize_type: SerializeType) -> Self

pub fn mark_response_type(self) -> Self

pub fn mark_oneway_rpc(self) -> Self

pub fn get_serialize_type(&self) -> SerializeType

pub fn header_encode(&self) -> Option<Bytes>

pub fn fast_header_encode(&self) -> Option<Bytes>

pub fn get_body(&self) -> Option<Bytes>

pub fn mark_serialize_type( header_length: i32, protocol_type: SerializeType ) -> i32

pub fn get_header_length(size: usize) -> usize

pub fn code(&self) -> i32

pub fn language(&self) -> &LanguageCode

pub fn version(&self) -> i32

pub fn opaque(&self) -> i32

pub fn flag(&self) -> i32

pub fn remark(&self) -> &Option<String>

pub fn ext_fields(&self) -> &Option<HashMap<String, String>>

pub fn body(&self) -> &Option<Bytes>

pub fn suspended(&self) -> bool

pub fn command_custom_header( &self ) -> &Option<Box<dyn CommandCustomHeader + Send + 'static>>

pub fn serialize_type(&self) -> SerializeType

pub fn decode_command_custom_header<T>(&self) -> Option<T>

where T: FromMap<Target = T>,

Trait Implementations

impl Default for RemotingCommand

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for RemotingCommand

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Encoder<RemotingCommand> for RemotingCommandCodec

type Error = RemotingError

The type of encoding errors.

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

Encodes a frame into the buffer provided.

impl Serialize for RemotingCommand

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.