pulsar_admin_sdk/models/
consumer_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 ConsumerStats {
15    #[serde(rename = "address", skip_serializing_if = "Option::is_none")]
16    pub address: Option<String>,
17    #[serde(rename = "availablePermits", skip_serializing_if = "Option::is_none")]
18    pub available_permits: Option<i32>,
19    #[serde(rename = "avgMessagesPerEntry", skip_serializing_if = "Option::is_none")]
20    pub avg_messages_per_entry: Option<i32>,
21    #[serde(rename = "blockedConsumerOnUnackedMsgs", skip_serializing_if = "Option::is_none")]
22    pub blocked_consumer_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 = "clientVersion", skip_serializing_if = "Option::is_none")]
28    pub client_version: Option<String>,
29    #[serde(rename = "connectedSince", skip_serializing_if = "Option::is_none")]
30    pub connected_since: Option<String>,
31    #[serde(rename = "consumerName", skip_serializing_if = "Option::is_none")]
32    pub consumer_name: Option<String>,
33    #[serde(rename = "keyHashRanges", skip_serializing_if = "Option::is_none")]
34    pub key_hash_ranges: Option<Vec<String>>,
35    #[serde(rename = "lastAckedTimestamp", skip_serializing_if = "Option::is_none")]
36    pub last_acked_timestamp: Option<i64>,
37    #[serde(rename = "lastConsumedFlowTimestamp", skip_serializing_if = "Option::is_none")]
38    pub last_consumed_flow_timestamp: Option<i64>,
39    #[serde(rename = "lastConsumedTimestamp", skip_serializing_if = "Option::is_none")]
40    pub last_consumed_timestamp: Option<i64>,
41    #[serde(rename = "messageAckRate", skip_serializing_if = "Option::is_none")]
42    pub message_ack_rate: Option<f64>,
43    #[serde(rename = "metadata", skip_serializing_if = "Option::is_none")]
44    pub metadata: Option<std::collections::HashMap<String, String>>,
45    #[serde(rename = "msgOutCounter", skip_serializing_if = "Option::is_none")]
46    pub msg_out_counter: Option<i64>,
47    #[serde(rename = "msgRateOut", skip_serializing_if = "Option::is_none")]
48    pub msg_rate_out: Option<f64>,
49    #[serde(rename = "msgRateRedeliver", skip_serializing_if = "Option::is_none")]
50    pub msg_rate_redeliver: Option<f64>,
51    #[serde(rename = "msgThroughputOut", skip_serializing_if = "Option::is_none")]
52    pub msg_throughput_out: Option<f64>,
53    #[serde(rename = "readPositionWhenJoining", skip_serializing_if = "Option::is_none")]
54    pub read_position_when_joining: Option<String>,
55    #[serde(rename = "unackedMessages", skip_serializing_if = "Option::is_none")]
56    pub unacked_messages: Option<i32>,
57}
58
59impl ConsumerStats {
60    pub fn new() -> ConsumerStats {
61        ConsumerStats {
62            address: None,
63            available_permits: None,
64            avg_messages_per_entry: None,
65            blocked_consumer_on_unacked_msgs: None,
66            bytes_out_counter: None,
67            chunked_message_rate: None,
68            client_version: None,
69            connected_since: None,
70            consumer_name: None,
71            key_hash_ranges: None,
72            last_acked_timestamp: None,
73            last_consumed_flow_timestamp: None,
74            last_consumed_timestamp: None,
75            message_ack_rate: None,
76            metadata: None,
77            msg_out_counter: None,
78            msg_rate_out: None,
79            msg_rate_redeliver: None,
80            msg_throughput_out: None,
81            read_position_when_joining: None,
82            unacked_messages: None,
83        }
84    }
85}
86
pulsar_admin_sdk/models/consumer_stats.rs

pulsar_admin_sdk/models/
consumer_stats.rs
