Struct ExtraInfoUtil 

pub struct ExtraInfoUtil;

Implementations

impl ExtraInfoUtil

pub fn parse_ack_extra_info(extra_info: &str) -> Result<AckExtraInfo<'_>>

Parses the fixed POP receipt-handle prefix without allocating its fields.

pub fn split(extra_info: &str) -> Vec<String>

Split the extra info string using the key separator

pub fn get_ck_queue_offset(extra_info_strs: &[String]) -> Result<i64>

Get the checkpoint queue offset from the extra info

pub fn get_pop_time(extra_info_strs: &[String]) -> Result<i64>

Get the pop time from the extra info

pub fn get_invisible_time(extra_info_strs: &[String]) -> Result<i64>

Get the invisible time from the extra info

pub fn get_revive_qid(extra_info_strs: &[String]) -> Result<i32>

Get the revive queue ID from the extra info

pub fn get_real_topic( extra_info_strs: &[String], topic: &str, cid: &str, ) -> Result<String>

Get the real topic name based on the retry flag

pub fn get_real_topic_with_retry( topic: &str, cid: &str, retry: &str, ) -> Result<String>

Get the real topic name based on the retry flag

pub fn get_retry(extra_info_strs: &[String]) -> Result<String>

Get the retry flag from the extra info

pub fn get_broker_name(extra_info_strs: &[String]) -> Result<String>

Get the broker name from the extra info

pub fn get_queue_id(extra_info_strs: &[String]) -> Result<i32>

Get the queue ID from the extra info

pub fn get_queue_offset(extra_info_strs: &[String]) -> Result<i64>

Get the queue offset from the extra info

pub fn build_extra_info( ck_queue_offset: i64, pop_time: i64, invisible_time: i64, revive_qid: i32, topic: &str, broker_name: &str, queue_id: i32, ) -> String

Build extra info string

pub fn build_extra_info_with_offset( ck_queue_offset: i64, pop_time: i64, invisible_time: i64, revive_qid: i32, topic: &str, broker_name: &str, queue_id: i32, msg_queue_offset: i64, ) -> String

Build extra info string with queue offset

pub fn build_extra_info_with_offset_and_retry_policy( ck_queue_offset: i64, pop_time: i64, invisible_time: i64, revive_qid: i32, topic: &str, broker_name: &str, queue_id: i32, msg_queue_offset: i64, retry_policy: &PopRetryPolicy, ) -> String

Builds a receipt handle that carries the persisted POP retry policy generation.

Existing eight-field handles remain valid. The optional ninth field is emitted only for retry topics, while the existing retry marker continues to identify v1 or v2.

pub fn build_start_offset_info( string_builder: &mut String, topic: &str, queue_id: i32, start_offset: i64, )

Build start offset info

pub fn build_queue_id_order_count_info( string_builder: &mut String, topic: &str, queue_id: i32, order_count: i32, )

Build queue ID order count info

pub fn build_queue_offset_order_count_info( string_builder: &mut String, topic: &str, queue_id: i64, queue_offset: i64, order_count: i32, )

Build queue offset order count info

pub fn build_msg_offset_info( string_builder: &mut String, topic: &str, queue_id: i32, msg_offsets: &[u64], )

Build message offset info

pub fn parse_msg_offset_info( msg_offset_info: &str, ) -> Result<HashMap<String, Vec<i64>>>

Parse message offset info into a HashMap

pub fn parse_start_offset_info( start_offset_info: &str, ) -> Result<HashMap<String, i64>>

Parse start offset info into a HashMap

pub fn parse_order_count_info( order_count_info: &str, ) -> Result<HashMap<String, i32>>

Parse order count info into a HashMap

pub fn get_start_offset_info_map_key(topic: &str, key: i64) -> String

Get start offset info map key

pub fn get_start_offset_info_map_key_with_pop_ck( topic: &str, pop_ck: Option<&str>, key: i64, ) -> Result<String>

Get start offset info map key with pop check

pub fn get_queue_offset_key_value_key( queue_id: i64, queue_offset: i64, ) -> String

Get queue offset key value key

pub fn get_queue_offset_map_key( topic: &str, queue_id: i64, queue_offset: i64, ) -> String

Get queue offset map key

pub fn is_order(extra_info: &[String]) -> bool

Check if the extra info represents an order