pulsar_admin_sdk/models/
non_persistent_subscription_stats.rs

1/*
2 * Pulsar Admin REST API
3 *
4 * This provides the REST API for admin operations
5 *
6 * The version of the OpenAPI document: v2
7 * 
8 * Generated by: https://openapi-generator.tech
9 */
10
11use crate::models;
12
13#[derive(Clone, Default, Debug, PartialEq, Serialize, Deserialize)]
14pub struct NonPersistentSubscriptionStats {
15    #[serde(rename = "activeConsumerName", skip_serializing_if = "Option::is_none")]
16    pub active_consumer_name: Option<String>,
17    #[serde(rename = "allowOutOfOrderDelivery", skip_serializing_if = "Option::is_none")]
18    pub allow_out_of_order_delivery: Option<bool>,
19    #[serde(rename = "backlogSize", skip_serializing_if = "Option::is_none")]
20    pub backlog_size: Option<i64>,
21    #[serde(rename = "blockedSubscriptionOnUnackedMsgs", skip_serializing_if = "Option::is_none")]
22    pub blocked_subscription_on_unacked_msgs: Option<bool>,
23    #[serde(rename = "bytesOutCounter", skip_serializing_if = "Option::is_none")]
24    pub bytes_out_counter: Option<i64>,
25    #[serde(rename = "chunkedMessageRate", skip_serializing_if = "Option::is_none")]
26    pub chunked_message_rate: Option<f64>,
27    #[serde(rename = "consumers", skip_serializing_if = "Option::is_none")]
28    pub consumers: Option<Vec<models::ConsumerStats>>,
29    #[serde(rename = "consumersAfterMarkDeletePosition", skip_serializing_if = "Option::is_none")]
30    pub consumers_after_mark_delete_position: Option<std::collections::HashMap<String, String>>,
31    #[serde(rename = "delayedMessageIndexSizeInBytes", skip_serializing_if = "Option::is_none")]
32    pub delayed_message_index_size_in_bytes: Option<i64>,
33    #[serde(rename = "durable", skip_serializing_if = "Option::is_none")]
34    pub durable: Option<bool>,
35    #[serde(rename = "earliestMsgPublishTimeInBacklog", skip_serializing_if = "Option::is_none")]
36    pub earliest_msg_publish_time_in_backlog: Option<i64>,
37    #[serde(rename = "filterAcceptedMsgCount", skip_serializing_if = "Option::is_none")]
38    pub filter_accepted_msg_count: Option<i64>,
39    #[serde(rename = "filterProcessedMsgCount", skip_serializing_if = "Option::is_none")]
40    pub filter_processed_msg_count: Option<i64>,
41    #[serde(rename = "filterRejectedMsgCount", skip_serializing_if = "Option::is_none")]
42    pub filter_rejected_msg_count: Option<i64>,
43    #[serde(rename = "filterRescheduledMsgCount", skip_serializing_if = "Option::is_none")]
44    pub filter_rescheduled_msg_count: Option<i64>,
45    #[serde(rename = "keySharedMode", skip_serializing_if = "Option::is_none")]
46    pub key_shared_mode: Option<String>,
47    #[serde(rename = "lastAckedTimestamp", skip_serializing_if = "Option::is_none")]
48    pub last_acked_timestamp: Option<i64>,
49    #[serde(rename = "lastConsumedFlowTimestamp", skip_serializing_if = "Option::is_none")]
50    pub last_consumed_flow_timestamp: Option<i64>,
51    #[serde(rename = "lastConsumedTimestamp", skip_serializing_if = "Option::is_none")]
52    pub last_consumed_timestamp: Option<i64>,
53    #[serde(rename = "lastExpireTimestamp", skip_serializing_if = "Option::is_none")]
54    pub last_expire_timestamp: Option<i64>,
55    #[serde(rename = "lastMarkDeleteAdvancedTimestamp", skip_serializing_if = "Option::is_none")]
56    pub last_mark_delete_advanced_timestamp: Option<i64>,
57    #[serde(rename = "messageAckRate", skip_serializing_if = "Option::is_none")]
58    pub message_ack_rate: Option<f64>,
59    #[serde(rename = "msgBacklog", skip_serializing_if = "Option::is_none")]
60    pub msg_backlog: Option<i64>,
61    #[serde(rename = "msgBacklogNoDelayed", skip_serializing_if = "Option::is_none")]
62    pub msg_backlog_no_delayed: Option<i64>,
63    #[serde(rename = "msgDelayed", skip_serializing_if = "Option::is_none")]
64    pub msg_delayed: Option<i64>,
65    #[serde(rename = "msgDropRate", skip_serializing_if = "Option::is_none")]
66    pub msg_drop_rate: Option<f64>,
67    #[serde(rename = "msgOutCounter", skip_serializing_if = "Option::is_none")]
68    pub msg_out_counter: Option<i64>,
69    #[serde(rename = "msgRateExpired", skip_serializing_if = "Option::is_none")]
70    pub msg_rate_expired: Option<f64>,
71    #[serde(rename = "msgRateOut", skip_serializing_if = "Option::is_none")]
72    pub msg_rate_out: Option<f64>,
73    #[serde(rename = "msgRateRedeliver", skip_serializing_if = "Option::is_none")]
74    pub msg_rate_redeliver: Option<f64>,
75    #[serde(rename = "msgThroughputOut", skip_serializing_if = "Option::is_none")]
76    pub msg_throughput_out: Option<f64>,
77    #[serde(rename = "nonContiguousDeletedMessagesRanges", skip_serializing_if = "Option::is_none")]
78    pub non_contiguous_deleted_messages_ranges: Option<i32>,
79    #[serde(rename = "nonContiguousDeletedMessagesRangesSerializedSize", skip_serializing_if = "Option::is_none")]
80    pub non_contiguous_deleted_messages_ranges_serialized_size: Option<i32>,
81    #[serde(rename = "replicated", skip_serializing_if = "Option::is_none")]
82    pub replicated: Option<bool>,
83    #[serde(rename = "subscriptionProperties", skip_serializing_if = "Option::is_none")]
84    pub subscription_properties: Option<std::collections::HashMap<String, String>>,
85    #[serde(rename = "totalMsgExpired", skip_serializing_if = "Option::is_none")]
86    pub total_msg_expired: Option<i64>,
87    #[serde(rename = "type", skip_serializing_if = "Option::is_none")]
88    pub r#type: Option<String>,
89    #[serde(rename = "unackedMessages", skip_serializing_if = "Option::is_none")]
90    pub unacked_messages: Option<i64>,
91}
92
93impl NonPersistentSubscriptionStats {
94    pub fn new() -> NonPersistentSubscriptionStats {
95        NonPersistentSubscriptionStats {
96            active_consumer_name: None,
97            allow_out_of_order_delivery: None,
98            backlog_size: None,
99            blocked_subscription_on_unacked_msgs: None,
100            bytes_out_counter: None,
101            chunked_message_rate: None,
102            consumers: None,
103            consumers_after_mark_delete_position: None,
104            delayed_message_index_size_in_bytes: None,
105            durable: None,
106            earliest_msg_publish_time_in_backlog: None,
107            filter_accepted_msg_count: None,
108            filter_processed_msg_count: None,
109            filter_rejected_msg_count: None,
110            filter_rescheduled_msg_count: None,
111            key_shared_mode: None,
112            last_acked_timestamp: None,
113            last_consumed_flow_timestamp: None,
114            last_consumed_timestamp: None,
115            last_expire_timestamp: None,
116            last_mark_delete_advanced_timestamp: None,
117            message_ack_rate: None,
118            msg_backlog: None,
119            msg_backlog_no_delayed: None,
120            msg_delayed: None,
121            msg_drop_rate: None,
122            msg_out_counter: None,
123            msg_rate_expired: None,
124            msg_rate_out: None,
125            msg_rate_redeliver: None,
126            msg_throughput_out: None,
127            non_contiguous_deleted_messages_ranges: None,
128            non_contiguous_deleted_messages_ranges_serialized_size: None,
129            replicated: None,
130            subscription_properties: None,
131            total_msg_expired: None,
132            r#type: None,
133            unacked_messages: None,
134        }
135    }
136}
137
pulsar_admin_sdk/models/non_persistent_subscription_stats.rs

pulsar_admin_sdk/models/
non_persistent_subscription_stats.rs
