Struct ConsumerStatsManager 

pub struct ConsumerStatsManager { /* private fields */ }

Tracks consumer-side statistics for each topic/group pair.

Maintains five time-windowed metric sets: consume OK TPS, consume failed TPS, consume RT, pull TPS, and pull RT. All inc_* methods are thread-safe and intended to be called on the hot consumption path.

Implementations

impl ConsumerStatsManager

pub fn new() -> Self

Creates a new ConsumerStatsManager with all metric sets initialised.

pub fn start(&self)

Starts background sampling tasks.

Spawns three Tokio tasks that advance the sliding-window snapshots used by consume_status:

• every 10 s → cs_list_minute (drives per-minute stats)
• every 10 min → cs_list_hour (drives per-hour stats)
• every 1 h → cs_list_day (drives per-day stats)

pub fn shutdown(&self)

Shuts down the stats manager.

pub fn inc_pull_rt(&self, group: &str, topic: &str, rt: u64)

Records a single pull response-time observation in milliseconds.

pub fn inc_pull_tps(&self, group: &str, topic: &str, msgs: u64)

Records msgs messages successfully pulled in one batch.

pub fn inc_consume_rt(&self, group: &str, topic: &str, rt: u64)

Records a single consume response-time observation in milliseconds.

pub fn inc_consume_ok_tps(&self, group: &str, topic: &str, msgs: u64)

Records msgs messages consumed successfully in one batch.

pub fn inc_consume_failed_tps(&self, group: &str, topic: &str, msgs: u64)

Records msgs messages that failed consumption in one batch.

pub fn consume_status(&self, group: &str, topic: &str) -> ConsumeStatus

Returns a point-in-time ConsumeStatus snapshot for the given consumer group and topic.

• Pull / consume RT uses the per-minute average; consume RT falls back to the per-hour average when the per-minute window is empty.
• consume_failed_msgs accumulates the per-hour sum of failed messages.

Trait Implementations

impl Default for ConsumerStatsManager

fn default() -> Self

Returns the “default value” for a type.