pulsar_admin_sdk/models/
partitioned_topic_stats_impl.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 PartitionedTopicStatsImpl {
15    #[serde(rename = "abortedTxnCount", skip_serializing_if = "Option::is_none")]
16    pub aborted_txn_count: Option<i64>,
17    #[serde(rename = "averageMsgSize", skip_serializing_if = "Option::is_none")]
18    pub average_msg_size: Option<f64>,
19    #[serde(rename = "backlogQuotaLimitSize", skip_serializing_if = "Option::is_none")]
20    pub backlog_quota_limit_size: Option<i64>,
21    #[serde(rename = "backlogQuotaLimitTime", skip_serializing_if = "Option::is_none")]
22    pub backlog_quota_limit_time: Option<i64>,
23    #[serde(rename = "backlogSize", skip_serializing_if = "Option::is_none")]
24    pub backlog_size: Option<i64>,
25    #[serde(rename = "bytesInCounter", skip_serializing_if = "Option::is_none")]
26    pub bytes_in_counter: Option<i64>,
27    #[serde(rename = "bytesOutCounter", skip_serializing_if = "Option::is_none")]
28    pub bytes_out_counter: Option<i64>,
29    #[serde(rename = "committedTxnCount", skip_serializing_if = "Option::is_none")]
30    pub committed_txn_count: Option<i64>,
31    #[serde(rename = "compaction", skip_serializing_if = "Option::is_none")]
32    pub compaction: Option<Box<models::CompactionStatsImpl>>,
33    #[serde(rename = "deduplicationStatus", skip_serializing_if = "Option::is_none")]
34    pub deduplication_status: Option<String>,
35    #[serde(rename = "delayedMessageIndexSizeInBytes", skip_serializing_if = "Option::is_none")]
36    pub delayed_message_index_size_in_bytes: Option<i64>,
37    #[serde(rename = "earliestMsgPublishTimeInBacklogs", skip_serializing_if = "Option::is_none")]
38    pub earliest_msg_publish_time_in_backlogs: Option<i64>,
39    #[serde(rename = "lastOffloadFailureTimeStamp", skip_serializing_if = "Option::is_none")]
40    pub last_offload_failure_time_stamp: Option<i64>,
41    #[serde(rename = "lastOffloadLedgerId", skip_serializing_if = "Option::is_none")]
42    pub last_offload_ledger_id: Option<i64>,
43    #[serde(rename = "lastOffloadSuccessTimeStamp", skip_serializing_if = "Option::is_none")]
44    pub last_offload_success_time_stamp: Option<i64>,
45    #[serde(rename = "metadata", skip_serializing_if = "Option::is_none")]
46    pub metadata: Option<Box<models::PartitionedTopicMetadata>>,
47    #[serde(rename = "msgChunkPublished", skip_serializing_if = "Option::is_none")]
48    pub msg_chunk_published: Option<bool>,
49    #[serde(rename = "msgInCounter", skip_serializing_if = "Option::is_none")]
50    pub msg_in_counter: Option<i64>,
51    #[serde(rename = "msgOutCounter", skip_serializing_if = "Option::is_none")]
52    pub msg_out_counter: Option<i64>,
53    #[serde(rename = "msgRateIn", skip_serializing_if = "Option::is_none")]
54    pub msg_rate_in: Option<f64>,
55    #[serde(rename = "msgRateOut", skip_serializing_if = "Option::is_none")]
56    pub msg_rate_out: Option<f64>,
57    #[serde(rename = "msgThroughputIn", skip_serializing_if = "Option::is_none")]
58    pub msg_throughput_in: Option<f64>,
59    #[serde(rename = "msgThroughputOut", skip_serializing_if = "Option::is_none")]
60    pub msg_throughput_out: Option<f64>,
61    #[serde(rename = "nonContiguousDeletedMessagesRanges", skip_serializing_if = "Option::is_none")]
62    pub non_contiguous_deleted_messages_ranges: Option<i32>,
63    #[serde(rename = "nonContiguousDeletedMessagesRangesSerializedSize", skip_serializing_if = "Option::is_none")]
64    pub non_contiguous_deleted_messages_ranges_serialized_size: Option<i32>,
65    #[serde(rename = "offloadedStorageSize", skip_serializing_if = "Option::is_none")]
66    pub offloaded_storage_size: Option<i64>,
67    #[serde(rename = "oldestBacklogMessageAgeSeconds", skip_serializing_if = "Option::is_none")]
68    pub oldest_backlog_message_age_seconds: Option<i64>,
69    #[serde(rename = "oldestBacklogMessageSubscriptionName", skip_serializing_if = "Option::is_none")]
70    pub oldest_backlog_message_subscription_name: Option<String>,
71    #[serde(rename = "ongoingTxnCount", skip_serializing_if = "Option::is_none")]
72    pub ongoing_txn_count: Option<i64>,
73    #[serde(rename = "ownerBroker", skip_serializing_if = "Option::is_none")]
74    pub owner_broker: Option<String>,
75    #[serde(rename = "partitions", skip_serializing_if = "Option::is_none")]
76    pub partitions: Option<std::collections::HashMap<String, models::TopicStats>>,
77    #[serde(rename = "publishRateLimitedTimes", skip_serializing_if = "Option::is_none")]
78    pub publish_rate_limited_times: Option<i64>,
79    #[serde(rename = "publishers", skip_serializing_if = "Option::is_none")]
80    pub publishers: Option<Vec<models::PublisherStats>>,
81    #[serde(rename = "replication", skip_serializing_if = "Option::is_none")]
82    pub replication: Option<std::collections::HashMap<String, models::ReplicatorStats>>,
83    #[serde(rename = "storageSize", skip_serializing_if = "Option::is_none")]
84    pub storage_size: Option<i64>,
85    #[serde(rename = "subscriptions", skip_serializing_if = "Option::is_none")]
86    pub subscriptions: Option<std::collections::HashMap<String, models::SubscriptionStats>>,
87    #[serde(rename = "topicEpoch", skip_serializing_if = "Option::is_none")]
88    pub topic_epoch: Option<i64>,
89    #[serde(rename = "waitingPublishers", skip_serializing_if = "Option::is_none")]
90    pub waiting_publishers: Option<i32>,
91}
92
93impl PartitionedTopicStatsImpl {
94    pub fn new() -> PartitionedTopicStatsImpl {
95        PartitionedTopicStatsImpl {
96            aborted_txn_count: None,
97            average_msg_size: None,
98            backlog_quota_limit_size: None,
99            backlog_quota_limit_time: None,
100            backlog_size: None,
101            bytes_in_counter: None,
102            bytes_out_counter: None,
103            committed_txn_count: None,
104            compaction: None,
105            deduplication_status: None,
106            delayed_message_index_size_in_bytes: None,
107            earliest_msg_publish_time_in_backlogs: None,
108            last_offload_failure_time_stamp: None,
109            last_offload_ledger_id: None,
110            last_offload_success_time_stamp: None,
111            metadata: None,
112            msg_chunk_published: None,
113            msg_in_counter: None,
114            msg_out_counter: None,
115            msg_rate_in: None,
116            msg_rate_out: None,
117            msg_throughput_in: None,
118            msg_throughput_out: None,
119            non_contiguous_deleted_messages_ranges: None,
120            non_contiguous_deleted_messages_ranges_serialized_size: None,
121            offloaded_storage_size: None,
122            oldest_backlog_message_age_seconds: None,
123            oldest_backlog_message_subscription_name: None,
124            ongoing_txn_count: None,
125            owner_broker: None,
126            partitions: None,
127            publish_rate_limited_times: None,
128            publishers: None,
129            replication: None,
130            storage_size: None,
131            subscriptions: None,
132            topic_epoch: None,
133            waiting_publishers: None,
134        }
135    }
136}
137
pulsar_admin_sdk/models/partitioned_topic_stats_impl.rs

pulsar_admin_sdk/models/
partitioned_topic_stats_impl.rs
