pulsar_admin_sdk/models/
persistent_topic_internal_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 PersistentTopicInternalStats {
15    #[serde(rename = "compactedLedger", skip_serializing_if = "Option::is_none")]
16    pub compacted_ledger: Option<Box<models::LedgerInfo>>,
17    #[serde(rename = "currentLedgerEntries", skip_serializing_if = "Option::is_none")]
18    pub current_ledger_entries: Option<i64>,
19    #[serde(rename = "currentLedgerSize", skip_serializing_if = "Option::is_none")]
20    pub current_ledger_size: Option<i64>,
21    #[serde(rename = "cursors", skip_serializing_if = "Option::is_none")]
22    pub cursors: Option<std::collections::HashMap<String, models::CursorStats>>,
23    #[serde(rename = "entriesAddedCounter", skip_serializing_if = "Option::is_none")]
24    pub entries_added_counter: Option<i64>,
25    #[serde(rename = "lastConfirmedEntry", skip_serializing_if = "Option::is_none")]
26    pub last_confirmed_entry: Option<String>,
27    #[serde(rename = "lastLedgerCreatedTimestamp", skip_serializing_if = "Option::is_none")]
28    pub last_ledger_created_timestamp: Option<String>,
29    #[serde(rename = "lastLedgerCreationFailureTimestamp", skip_serializing_if = "Option::is_none")]
30    pub last_ledger_creation_failure_timestamp: Option<String>,
31    #[serde(rename = "ledgers", skip_serializing_if = "Option::is_none")]
32    pub ledgers: Option<Vec<models::LedgerInfo>>,
33    #[serde(rename = "numberOfEntries", skip_serializing_if = "Option::is_none")]
34    pub number_of_entries: Option<i64>,
35    #[serde(rename = "pendingAddEntriesCount", skip_serializing_if = "Option::is_none")]
36    pub pending_add_entries_count: Option<i32>,
37    #[serde(rename = "schemaLedgers", skip_serializing_if = "Option::is_none")]
38    pub schema_ledgers: Option<Vec<models::LedgerInfo>>,
39    #[serde(rename = "state", skip_serializing_if = "Option::is_none")]
40    pub state: Option<String>,
41    #[serde(rename = "totalSize", skip_serializing_if = "Option::is_none")]
42    pub total_size: Option<i64>,
43    #[serde(rename = "waitingCursorsCount", skip_serializing_if = "Option::is_none")]
44    pub waiting_cursors_count: Option<i32>,
45}
46
47impl PersistentTopicInternalStats {
48    pub fn new() -> PersistentTopicInternalStats {
49        PersistentTopicInternalStats {
50            compacted_ledger: None,
51            current_ledger_entries: None,
52            current_ledger_size: None,
53            cursors: None,
54            entries_added_counter: None,
55            last_confirmed_entry: None,
56            last_ledger_created_timestamp: None,
57            last_ledger_creation_failure_timestamp: None,
58            ledgers: None,
59            number_of_entries: None,
60            pending_add_entries_count: None,
61            schema_ledgers: None,
62            state: None,
63            total_size: None,
64            waiting_cursors_count: None,
65        }
66    }
67}
68
pulsar_admin_sdk/models/persistent_topic_internal_stats.rs

pulsar_admin_sdk/models/
persistent_topic_internal_stats.rs
