Struct SubscriptionStats 

pub struct SubscriptionStats {

    pub active_consumer_name: Option<String>,
    pub allow_out_of_order_delivery: Option<bool>,
    pub backlog_size: Option<i64>,
    pub blocked_subscription_on_unacked_msgs: Option<bool>,
    pub bytes_out_counter: Option<i64>,
    pub chunked_message_rate: Option<f64>,
    pub consumers: Option<Vec<ConsumerStats>>,
    pub consumers_after_mark_delete_position: Option<HashMap<String, String>>,
    pub delayed_message_index_size_in_bytes: Option<i64>,
    pub durable: Option<bool>,
    pub earliest_msg_publish_time_in_backlog: Option<i64>,
    pub filter_accepted_msg_count: Option<i64>,
    pub filter_processed_msg_count: Option<i64>,
    pub filter_rejected_msg_count: Option<i64>,
    pub filter_rescheduled_msg_count: Option<i64>,
    pub key_shared_mode: Option<String>,
    pub last_acked_timestamp: Option<i64>,
    pub last_consumed_flow_timestamp: Option<i64>,
    pub last_consumed_timestamp: Option<i64>,
    pub last_expire_timestamp: Option<i64>,
    pub last_mark_delete_advanced_timestamp: Option<i64>,
    pub message_ack_rate: Option<f64>,
    pub msg_backlog: Option<i64>,
    pub msg_backlog_no_delayed: Option<i64>,
    pub msg_delayed: Option<i64>,
    pub msg_out_counter: Option<i64>,
    pub msg_rate_expired: Option<f64>,
    pub msg_rate_out: Option<f64>,
    pub msg_rate_redeliver: Option<f64>,
    pub msg_throughput_out: Option<f64>,
    pub non_contiguous_deleted_messages_ranges: Option<i32>,
    pub non_contiguous_deleted_messages_ranges_serialized_size: Option<i32>,
    pub replicated: Option<bool>,
    pub subscription_properties: Option<HashMap<String, String>>,
    pub total_msg_expired: Option<i64>,
    pub type: Option<String>,
    pub unacked_messages: Option<i64>,
}

Fields

active_consumer_name: Option<String>

allow_out_of_order_delivery: Option<bool>

backlog_size: Option<i64>

blocked_subscription_on_unacked_msgs: Option<bool>

bytes_out_counter: Option<i64>

chunked_message_rate: Option<f64>

consumers: Option<Vec<ConsumerStats>>

consumers_after_mark_delete_position: Option<HashMap<String, String>>

delayed_message_index_size_in_bytes: Option<i64>

durable: Option<bool>

earliest_msg_publish_time_in_backlog: Option<i64>

filter_accepted_msg_count: Option<i64>

filter_processed_msg_count: Option<i64>

filter_rejected_msg_count: Option<i64>

filter_rescheduled_msg_count: Option<i64>

key_shared_mode: Option<String>

last_acked_timestamp: Option<i64>

last_consumed_flow_timestamp: Option<i64>

last_consumed_timestamp: Option<i64>

last_expire_timestamp: Option<i64>

last_mark_delete_advanced_timestamp: Option<i64>

message_ack_rate: Option<f64>

msg_backlog: Option<i64>

msg_backlog_no_delayed: Option<i64>

msg_delayed: Option<i64>

msg_out_counter: Option<i64>

msg_rate_expired: Option<f64>

msg_rate_out: Option<f64>

msg_rate_redeliver: Option<f64>

msg_throughput_out: Option<f64>

non_contiguous_deleted_messages_ranges: Option<i32>

non_contiguous_deleted_messages_ranges_serialized_size: Option<i32>

replicated: Option<bool>

subscription_properties: Option<HashMap<String, String>>

total_msg_expired: Option<i64>

type: Option<String>

unacked_messages: Option<i64>

Implementations

impl SubscriptionStats

pub fn new() -> SubscriptionStats

Trait Implementations

impl Clone for SubscriptionStats

fn clone(&self) -> SubscriptionStats

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SubscriptionStats

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

Formats the value using the given formatter.

impl Default for SubscriptionStats

fn default() -> SubscriptionStats

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for SubscriptionStats

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for SubscriptionStats

fn eq(&self, other: &SubscriptionStats) -> 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 SubscriptionStats

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 SubscriptionStats