pub struct Statistics {
Show 25 fields pub name: String, pub client_id: String, pub client_type: String, pub ts: i64, pub time: i64, pub age: i64, pub replyq: i64, pub msg_cnt: u64, pub msg_size: u64, pub msg_max: u64, pub msg_size_max: u64, pub tx: i64, pub tx_bytes: i64, pub rx: i64, pub rx_bytes: i64, pub txmsgs: i64, pub txmsg_bytes: i64, pub rxmsgs: i64, pub rxmsg_bytes: i64, pub simple_cnt: i64, pub metadata_cache_cnt: i64, pub brokers: HashMap<String, Broker>, pub topics: HashMap<String, Topic>, pub cgrp: Option<ConsumerGroup>, pub eos: Option<ExactlyOnceSemantics>,
}
Expand description

Overall statistics.

Fields

name: String

The name of the librdkafka handle.

client_id: String

The configured client.id.

client_type: String

The instance type (producer or consumer).

ts: i64

The current value of librdkafka’s internal monotonic clock, in

time: i64

Wall clock time, in seconds since the Unix epoch.

age: i64

Time since this client instance was created, in microseconds.

replyq: i64

The number of operations (callbacks, events, etc.) waiting in queue.

msg_cnt: u64

The current number of messages in producer queues.

msg_size: u64

The current total size of messages in producer queues.

msg_max: u64

The maximum number of messages allowed in the producer queues.

msg_size_max: u64

The maximum total size of messages allowed in the producer queues.

tx: i64

The total number of requests sent to brokers.

tx_bytes: i64

The total number of bytes transmitted to brokers.

rx: i64

The total number of responses received from brokers.

rx_bytes: i64

The total number of bytes received from brokers.

txmsgs: i64

The total number of messages transmitted (produced) to brokers.

txmsg_bytes: i64

The total number of bytes transmitted (produced) to brokers.

rxmsgs: i64

The total number of messages consumed from brokers, not including ignored messages.

rxmsg_bytes: i64

The total number of bytes (including framing) consumed from brokers.

simple_cnt: i64

Internal tracking of legacy vs. new consumer API state.

metadata_cache_cnt: i64

Number of topics in the metadata cache.

brokers: HashMap<String, Broker>

Per-broker statistics.

topics: HashMap<String, Topic>

Per-topic statistics.

cgrp: Option<ConsumerGroup>

Consumer group statistics.

eos: Option<ExactlyOnceSemantics>

Exactly-once semantics and idempotent producer statistics.

Trait Implementations

Formats the value using the given formatter. Read more

Returns the “default value” for a type. Read more

Deserialize this value from the given Serde deserializer. Read more

Auto Trait Implementations

Blanket Implementations

Gets the TypeId of self. Read more

Immutably borrows from an owned value. Read more

Mutably borrows from an owned value. Read more

Performs the conversion.

Performs the conversion.

The type returned in the event of a conversion error.

Performs the conversion.

The type returned in the event of a conversion error.

Performs the conversion.