Struct replicator::metrics::ObserverMetrics

pub struct ObserverMetrics {
    pub registry: Registry,
    pub namespace: String,
    pub const_labels: HashMap<String, String>,
    pub number_of_records_total: IntGaugeVec,
    pub partition_start_offset: IntGaugeVec,
    pub partition_end_offset: IntGaugeVec,
    pub number_of_records_for_partition: IntGaugeVec,
    pub last_fetch_ts: GaugeVec,
    pub commited_offset: IntGaugeVec,
    pub remaining_by_partition: IntGaugeVec,
    pub remaining_for_topic: IntGaugeVec,
}

Fields

registry: Registry

namespace: String

const_labels: HashMap<String, String>

number_of_records_total: IntGaugeVec

partition_start_offset: IntGaugeVec

partition_end_offset: IntGaugeVec

number_of_records_for_partition: IntGaugeVec

last_fetch_ts: GaugeVec

commited_offset: IntGaugeVec

remaining_by_partition: IntGaugeVec

remaining_for_topic: IntGaugeVec

Implementations

impl ObserverMetrics

pub fn new(
    namespace: Option<String>,
    labels: Option<HashMap<String, String>>
) -> Self

Trait Implementations

impl Debug for ObserverMetrics

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

Formats the value using the given formatter.

impl Metrics for ObserverMetrics

pub fn get_registry(&self) -> &Registry

pub fn get_metrics(&self) -> String