Struct TopicStats 

pub struct TopicStats {
    pub msg_rate_in: f64,
    pub msg_rate_out: f64,
    pub msg_throughput_in: f64,
    pub msg_throughput_out: f64,
    pub average_msg_size: f64,
    pub msg_in_counter: i64,
    pub bytes_in_counter: i64,
    pub storage_size: i64,
    pub backlog_size: i64,
    pub publishers: Vec<Value>,
    pub subscriptions: Value,
}

Topic stats. Intentionally permissive: the Java PersistentTopicStatsImpl shape is large and shifts between releases; we extract the high-signal rates, throughput, sizes, and counters and pass the rest through as raw JSON.

All scalar fields default to 0 / 0.0 when the broker omits them, so a release that drops or renames one decodes cleanly instead of failing the whole stats call.

Fields

msg_rate_in: f64

Current publish rate into the topic, in messages/sec, averaged over the broker’s most recent stats window. Java: PersistentTopicStats#msgRateIn.

msg_rate_out: f64

Current dispatch rate out of the topic, in messages/sec. Java: PersistentTopicStats#msgRateOut.

msg_throughput_in: f64

Current publish throughput into the topic, in bytes/sec. Java: PersistentTopicStats#msgThroughputIn.

msg_throughput_out: f64

Current dispatch throughput out of the topic, in bytes/sec. Java: PersistentTopicStats#msgThroughputOut.

average_msg_size: f64

Average message size, in bytes, over the most recent stats window. Java: PersistentTopicStats#averageMsgSize.

msg_in_counter: i64

Total messages received.

bytes_in_counter: i64

Total bytes received.

storage_size: i64

Total storage used by the topic’s managed ledger, in bytes (includes replicas). Java: PersistentTopicStats#storageSize.

backlog_size: i64

Current backlog size across all subscriptions, in bytes. Java: PersistentTopicStats#backlogSize.

publishers: Vec<Value>

Publishers, raw JSON because the schema is large and version-dependent.

subscriptions: Value

Subscriptions map (raw JSON).

Trait Implementations

impl Clone for TopicStats

fn clone(&self) -> TopicStats

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for TopicStats

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for TopicStats

fn default() -> TopicStats

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for TopicStats

where TopicStats: Default,

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.