Struct PullMessageRequestHeader

pub struct PullMessageRequestHeader {

    pub consumer_group: CheetahString,
    pub topic: CheetahString,
    pub queue_id: i32,
    pub queue_offset: i64,
    pub max_msg_nums: i32,
    pub sys_flag: i32,
    pub commit_offset: i64,
    pub suspend_timeout_millis: u64,
    pub sub_version: i64,
    pub subscription: Option<CheetahString>,
    pub expression_type: Option<CheetahString>,
    pub max_msg_bytes: Option<i32>,
    pub request_source: Option<i32>,
    pub proxy_forward_client_id: Option<CheetahString>,
    pub topic_request: Option<TopicRequestHeader>,
}

Fields

consumer_group: CheetahString

topic: CheetahString

queue_id: i32

queue_offset: i64

max_msg_nums: i32

sys_flag: i32

commit_offset: i64

suspend_timeout_millis: u64

sub_version: i64

subscription: Option<CheetahString>

expression_type: Option<CheetahString>

max_msg_bytes: Option<i32>

request_source: Option<i32>

proxy_forward_client_id: Option<CheetahString>

topic_request: Option<TopicRequestHeader>

Trait Implementations

impl Clone for PullMessageRequestHeader

fn clone(&self) -> PullMessageRequestHeader

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl CommandCustomHeader for PullMessageRequestHeader

fn to_map(&self) -> Option<HashMap<CheetahString, CheetahString>>

Converts the implementing type to a map.

fn check_fields(&self) -> Result<(), Error>

Checks the fields of the implementing type.

fn write_if_not_null(&self, out: &mut BytesMut, key: &str, value: &str)

Writes the provided key to the out buffer if the value is not empty.

fn encode_fast(&mut self, _out: &mut BytesMut)

A placeholder function for fast encoding.

fn decode_fast( &mut self, _fields: &HashMap<CheetahString, CheetahString>, ) -> RocketMQResult<()>

A placeholder function for fast decoding.

fn support_fast_codec(&self) -> bool

Indicates whether the implementing type supports fast codec.

fn get_and_check_not_none( &self, map: &HashMap<CheetahString, CheetahString>, field: &CheetahString, ) -> RocketMQResult<CheetahString>

Retrieves the value associated with the specified field from the provided map.

impl Debug for PullMessageRequestHeader

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

Formats the value using the given formatter.

impl Default for PullMessageRequestHeader

fn default() -> PullMessageRequestHeader

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for PullMessageRequestHeader

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl FromMap for PullMessageRequestHeader

type Error = RocketmqError

type Target = PullMessageRequestHeader

fn from( map: &HashMap<CheetahString, CheetahString>, ) -> Result<Self::Target, Self::Error>

Converts the implementing type from a map.

impl Serialize for PullMessageRequestHeader

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl TopicRequestHeaderTrait for PullMessageRequestHeader

fn set_lo(&mut self, lo: Option<bool>)

fn lo(&self) -> Option<bool>

fn set_topic(&mut self, topic: CheetahString)

fn topic(&self) -> &CheetahString

fn broker_name(&self) -> Option<&CheetahString>

fn set_broker_name(&mut self, broker_name: CheetahString)

fn namespace(&self) -> Option<&str>

fn set_namespace(&mut self, namespace: CheetahString)

fn namespaced(&self) -> Option<bool>

fn set_namespaced(&mut self, namespaced: bool)

fn oneway(&self) -> Option<bool>

fn set_oneway(&mut self, oneway: bool)

fn queue_id(&self) -> i32

fn set_queue_id(&mut self, queue_id: i32)