Struct SendResult 

pub struct SendResult {
    pub send_status: SendStatus,
    pub msg_id: Option<CheetahString>,
    pub message_queue: Option<MessageQueue>,
    pub queue_offset: u64,
    pub transaction_id: Option<String>,
    pub offset_msg_id: Option<String>,
    pub recall_handle: Option<String>,
    pub region_id: Option<String>,
    pub trace_on: bool,
    pub raw_resp_body: Option<Vec<u8>>,
}

Producer send result without client lifecycle state.

Fields

send_status: SendStatus

msg_id: Option<CheetahString>

message_queue: Option<MessageQueue>

queue_offset: u64

transaction_id: Option<String>

offset_msg_id: Option<String>

recall_handle: Option<String>

region_id: Option<String>

trace_on: bool

raw_resp_body: Option<Vec<u8>>

Implementations

impl SendResult

pub fn new( send_status: SendStatus, msg_id: Option<CheetahString>, offset_msg_id: Option<String>, message_queue: Option<MessageQueue>, queue_offset: u64, ) -> Self

pub fn new_with_additional_fields( send_status: SendStatus, msg_id: Option<CheetahString>, message_queue: Option<MessageQueue>, queue_offset: u64, transaction_id: Option<String>, offset_msg_id: Option<String>, region_id: Option<String>, ) -> Self

pub fn encoder_send_result_to_json<T: Serialize>(value: &T) -> Result<String>

pub fn decoder_send_result_from_json(json: &str) -> Result<Self>

pub fn is_trace_on(&self) -> bool

pub fn set_trace_on(&mut self, trace_on: bool)

pub fn get_region_id(&self) -> Option<&str>

pub fn set_region_id(&mut self, region_id: String)

pub fn get_msg_id(&self) -> Option<&CheetahString>

pub fn set_msg_id(&mut self, msg_id: CheetahString)

pub fn get_send_status(&self) -> SendStatus

pub fn set_send_status(&mut self, send_status: SendStatus)

pub fn get_message_queue(&self) -> Option<&MessageQueue>

pub fn set_message_queue(&mut self, message_queue: MessageQueue)

pub fn get_queue_offset(&self) -> u64

pub fn set_queue_offset(&mut self, queue_offset: u64)

pub fn get_transaction_id(&self) -> Option<&str>

pub fn set_transaction_id(&mut self, transaction_id: String)

pub fn get_offset_msg_id(&self) -> Option<&str>

pub fn set_offset_msg_id(&mut self, offset_msg_id: String)

pub fn set_recall_handle(&mut self, recall_handle: String)

pub fn recall_handle(&self) -> Option<&str>

pub fn get_recall_handle(&self) -> Option<&str>

pub fn set_raw_resp_body(&mut self, body: Vec<u8>)

pub fn get_raw_resp_body(&self) -> Option<&[u8]>

Trait Implementations

impl Clone for SendResult

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SendResult

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

Formats the value using the given formatter.

impl Default for SendResult

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for SendResult

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for SendResult

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

Formats the value using the given formatter.

impl Eq for SendResult

impl PartialEq for SendResult

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for SendResult

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for SendResult