Struct ConsumerStats 

pub struct ConsumerStats {

    pub address: Option<String>,
    pub available_permits: Option<i32>,
    pub avg_messages_per_entry: Option<i32>,
    pub blocked_consumer_on_unacked_msgs: Option<bool>,
    pub bytes_out_counter: Option<i64>,
    pub chunked_message_rate: Option<f64>,
    pub client_version: Option<String>,
    pub connected_since: Option<String>,
    pub consumer_name: Option<String>,
    pub key_hash_ranges: Option<Vec<String>>,
    pub last_acked_timestamp: Option<i64>,
    pub last_consumed_flow_timestamp: Option<i64>,
    pub last_consumed_timestamp: Option<i64>,
    pub message_ack_rate: Option<f64>,
    pub metadata: Option<HashMap<String, String>>,
    pub msg_out_counter: Option<i64>,
    pub msg_rate_out: Option<f64>,
    pub msg_rate_redeliver: Option<f64>,
    pub msg_throughput_out: Option<f64>,
    pub read_position_when_joining: Option<String>,
    pub unacked_messages: Option<i32>,
}

Fields

address: Option<String>

available_permits: Option<i32>

avg_messages_per_entry: Option<i32>

blocked_consumer_on_unacked_msgs: Option<bool>

bytes_out_counter: Option<i64>

chunked_message_rate: Option<f64>

client_version: Option<String>

connected_since: Option<String>

consumer_name: Option<String>

key_hash_ranges: Option<Vec<String>>

last_acked_timestamp: Option<i64>

last_consumed_flow_timestamp: Option<i64>

last_consumed_timestamp: Option<i64>

message_ack_rate: Option<f64>

metadata: Option<HashMap<String, String>>

msg_out_counter: Option<i64>

msg_rate_out: Option<f64>

msg_rate_redeliver: Option<f64>

msg_throughput_out: Option<f64>

read_position_when_joining: Option<String>

unacked_messages: Option<i32>

Implementations

impl ConsumerStats

pub fn new() -> ConsumerStats

Trait Implementations

impl Clone for ConsumerStats

fn clone(&self) -> ConsumerStats

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConsumerStats

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

Formats the value using the given formatter.

impl Default for ConsumerStats

fn default() -> ConsumerStats

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ConsumerStats

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for ConsumerStats

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for ConsumerStats

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 ConsumerStats