Struct ModuleMetrics 

pub struct ModuleMetrics {
    pub reads: BTreeMap<String, ReadMetrics>,
    pub writes: BTreeMap<String, WriteMetrics>,
}

Metrics for a single module/consumer/producer in the message bus.

A module is any component that reads from or writes to topics. This could be a microservice, a worker process, or any logical unit.

Fields

reads: BTreeMap<String, ReadMetrics>

Metrics for topics this module reads from (subscriptions).

writes: BTreeMap<String, WriteMetrics>

Metrics for topics this module writes to (publications).

Implementations

impl ModuleMetrics

pub fn new() -> Self

Create empty module metrics.

pub fn builder() -> ModuleMetricsBuilder

Create a builder for module metrics.

pub fn is_empty(&self) -> bool

Check if the module has any activity.

pub fn total_reads(&self) -> u64

Total messages read across all topics.

pub fn total_writes(&self) -> u64

Total messages written across all topics.

Trait Implementations

impl Clone for ModuleMetrics

fn clone(&self) -> ModuleMetrics

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ModuleMetrics

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

Formats the value using the given formatter.

impl Default for ModuleMetrics

fn default() -> ModuleMetrics

Returns the “default value” for a type.

impl PartialEq for ModuleMetrics

fn eq(&self, other: &ModuleMetrics) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for ModuleMetrics