pulsar_admin_sdk/models/
load_report.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 LoadReport {
15    #[serde(rename = "allocatedBandwidthIn", skip_serializing_if = "Option::is_none")]
16    pub allocated_bandwidth_in: Option<f64>,
17    #[serde(rename = "allocatedBandwidthOut", skip_serializing_if = "Option::is_none")]
18    pub allocated_bandwidth_out: Option<f64>,
19    #[serde(rename = "allocatedCPU", skip_serializing_if = "Option::is_none")]
20    pub allocated_cpu: Option<f64>,
21    #[serde(rename = "allocatedMemory", skip_serializing_if = "Option::is_none")]
22    pub allocated_memory: Option<f64>,
23    #[serde(rename = "allocatedMsgRateIn", skip_serializing_if = "Option::is_none")]
24    pub allocated_msg_rate_in: Option<f64>,
25    #[serde(rename = "allocatedMsgRateOut", skip_serializing_if = "Option::is_none")]
26    pub allocated_msg_rate_out: Option<f64>,
27    #[serde(rename = "bandwidthIn", skip_serializing_if = "Option::is_none")]
28    pub bandwidth_in: Option<Box<models::ResourceUsage>>,
29    #[serde(rename = "bandwidthOut", skip_serializing_if = "Option::is_none")]
30    pub bandwidth_out: Option<Box<models::ResourceUsage>>,
31    #[serde(rename = "brokerVersionString", skip_serializing_if = "Option::is_none")]
32    pub broker_version_string: Option<String>,
33    #[serde(rename = "bundleGains", skip_serializing_if = "Option::is_none")]
34    pub bundle_gains: Option<Vec<String>>,
35    #[serde(rename = "bundleLosses", skip_serializing_if = "Option::is_none")]
36    pub bundle_losses: Option<Vec<String>>,
37    #[serde(rename = "bundleStats", skip_serializing_if = "Option::is_none")]
38    pub bundle_stats: Option<std::collections::HashMap<String, models::NamespaceBundleStats>>,
39    #[serde(rename = "cpu", skip_serializing_if = "Option::is_none")]
40    pub cpu: Option<Box<models::ResourceUsage>>,
41    #[serde(rename = "directMemory", skip_serializing_if = "Option::is_none")]
42    pub direct_memory: Option<Box<models::ResourceUsage>>,
43    #[serde(rename = "lastUpdate", skip_serializing_if = "Option::is_none")]
44    pub last_update: Option<i64>,
45    #[serde(rename = "loadManagerClassName", skip_serializing_if = "Option::is_none")]
46    pub load_manager_class_name: Option<String>,
47    #[serde(rename = "loadReportType", skip_serializing_if = "Option::is_none")]
48    pub load_report_type: Option<String>,
49    #[serde(rename = "memory", skip_serializing_if = "Option::is_none")]
50    pub memory: Option<Box<models::ResourceUsage>>,
51    #[serde(rename = "msgRateIn", skip_serializing_if = "Option::is_none")]
52    pub msg_rate_in: Option<f64>,
53    #[serde(rename = "msgRateOut", skip_serializing_if = "Option::is_none")]
54    pub msg_rate_out: Option<f64>,
55    #[serde(rename = "msgThroughputIn", skip_serializing_if = "Option::is_none")]
56    pub msg_throughput_in: Option<f64>,
57    #[serde(rename = "msgThroughputOut", skip_serializing_if = "Option::is_none")]
58    pub msg_throughput_out: Option<f64>,
59    #[serde(rename = "name", skip_serializing_if = "Option::is_none")]
60    pub name: Option<String>,
61    #[serde(rename = "nonPersistentTopicsEnabled", skip_serializing_if = "Option::is_none")]
62    pub non_persistent_topics_enabled: Option<bool>,
63    #[serde(rename = "numBundles", skip_serializing_if = "Option::is_none")]
64    pub num_bundles: Option<i32>,
65    #[serde(rename = "numConsumers", skip_serializing_if = "Option::is_none")]
66    pub num_consumers: Option<i32>,
67    #[serde(rename = "numProducers", skip_serializing_if = "Option::is_none")]
68    pub num_producers: Option<i32>,
69    #[serde(rename = "numTopics", skip_serializing_if = "Option::is_none")]
70    pub num_topics: Option<i64>,
71    #[serde(rename = "overLoaded", skip_serializing_if = "Option::is_none")]
72    pub over_loaded: Option<bool>,
73    #[serde(rename = "persistentTopicsEnabled", skip_serializing_if = "Option::is_none")]
74    pub persistent_topics_enabled: Option<bool>,
75    #[serde(rename = "preAllocatedBandwidthIn", skip_serializing_if = "Option::is_none")]
76    pub pre_allocated_bandwidth_in: Option<f64>,
77    #[serde(rename = "preAllocatedBandwidthOut", skip_serializing_if = "Option::is_none")]
78    pub pre_allocated_bandwidth_out: Option<f64>,
79    #[serde(rename = "preAllocatedCPU", skip_serializing_if = "Option::is_none")]
80    pub pre_allocated_cpu: Option<f64>,
81    #[serde(rename = "preAllocatedMemory", skip_serializing_if = "Option::is_none")]
82    pub pre_allocated_memory: Option<f64>,
83    #[serde(rename = "preAllocatedMsgRateIn", skip_serializing_if = "Option::is_none")]
84    pub pre_allocated_msg_rate_in: Option<f64>,
85    #[serde(rename = "preAllocatedMsgRateOut", skip_serializing_if = "Option::is_none")]
86    pub pre_allocated_msg_rate_out: Option<f64>,
87    #[serde(rename = "protocols", skip_serializing_if = "Option::is_none")]
88    pub protocols: Option<std::collections::HashMap<String, String>>,
89    #[serde(rename = "pulsarServiceUrl", skip_serializing_if = "Option::is_none")]
90    pub pulsar_service_url: Option<String>,
91    #[serde(rename = "pulsarServiceUrlTls", skip_serializing_if = "Option::is_none")]
92    pub pulsar_service_url_tls: Option<String>,
93    #[serde(rename = "startTimestamp", skip_serializing_if = "Option::is_none")]
94    pub start_timestamp: Option<i64>,
95    #[serde(rename = "systemResourceUsage", skip_serializing_if = "Option::is_none")]
96    pub system_resource_usage: Option<Box<models::SystemResourceUsage>>,
97    #[serde(rename = "timestamp", skip_serializing_if = "Option::is_none")]
98    pub timestamp: Option<i64>,
99    #[serde(rename = "underLoaded", skip_serializing_if = "Option::is_none")]
100    pub under_loaded: Option<bool>,
101    #[serde(rename = "webServiceUrl", skip_serializing_if = "Option::is_none")]
102    pub web_service_url: Option<String>,
103    #[serde(rename = "webServiceUrlTls", skip_serializing_if = "Option::is_none")]
104    pub web_service_url_tls: Option<String>,
105}
106
107impl LoadReport {
108    pub fn new() -> LoadReport {
109        LoadReport {
110            allocated_bandwidth_in: None,
111            allocated_bandwidth_out: None,
112            allocated_cpu: None,
113            allocated_memory: None,
114            allocated_msg_rate_in: None,
115            allocated_msg_rate_out: None,
116            bandwidth_in: None,
117            bandwidth_out: None,
118            broker_version_string: None,
119            bundle_gains: None,
120            bundle_losses: None,
121            bundle_stats: None,
122            cpu: None,
123            direct_memory: None,
124            last_update: None,
125            load_manager_class_name: None,
126            load_report_type: None,
127            memory: None,
128            msg_rate_in: None,
129            msg_rate_out: None,
130            msg_throughput_in: None,
131            msg_throughput_out: None,
132            name: None,
133            non_persistent_topics_enabled: None,
134            num_bundles: None,
135            num_consumers: None,
136            num_producers: None,
137            num_topics: None,
138            over_loaded: None,
139            persistent_topics_enabled: None,
140            pre_allocated_bandwidth_in: None,
141            pre_allocated_bandwidth_out: None,
142            pre_allocated_cpu: None,
143            pre_allocated_memory: None,
144            pre_allocated_msg_rate_in: None,
145            pre_allocated_msg_rate_out: None,
146            protocols: None,
147            pulsar_service_url: None,
148            pulsar_service_url_tls: None,
149            start_timestamp: None,
150            system_resource_usage: None,
151            timestamp: None,
152            under_loaded: None,
153            web_service_url: None,
154            web_service_url_tls: None,
155        }
156    }
157}
158
pulsar_admin_sdk/models/load_report.rs

pulsar_admin_sdk/models/
load_report.rs
