Struct pulsar_admin_sdk::models::non_persistent_subscription_stats::NonPersistentSubscriptionStats

pub struct NonPersistentSubscriptionStats {

    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<i32>,
    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_drop_rate: Option<f64>,
    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<i32>

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_drop_rate: Option<f64>

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 NonPersistentSubscriptionStats

pub fn new() -> NonPersistentSubscriptionStats

Trait Implementations

impl Clone for NonPersistentSubscriptionStats

fn clone(&self) -> NonPersistentSubscriptionStats

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for NonPersistentSubscriptionStats

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

Formats the value using the given formatter.

impl Default for NonPersistentSubscriptionStats

fn default() -> NonPersistentSubscriptionStats

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for NonPersistentSubscriptionStats

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for NonPersistentSubscriptionStats

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

This method tests for self and other values to be equal, and is used by ==.

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

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

impl Serialize for NonPersistentSubscriptionStats

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 NonPersistentSubscriptionStats