Struct SourceMetrics 

pub struct SourceMetrics { /* private fields */ }

Source-stage handles (etl_source_*).

Implementations

impl SourceMetrics

pub fn new(labels: &ComponentLabels, per_partition_detail: bool) -> Self

Resolve all source handles. per_partition_detail gates the cardinality-sensitive per-partition lag series.

pub fn batch(&self, records: u64, bytes: u64)

Record one polled batch.

pub fn poll_duration(&self, d: Duration)

Observe one poll call’s duration.

pub fn set_lag_max(&self, lag: u64)

Set the max consumer lag across partitions.

pub fn set_partition_lag(&self, partition: PartitionId, lag: u64)

Set one partition’s lag. No-op unless per_partition_detail.

pub fn retain_partitions(&self, keep: &[PartitionId])

Drop per-partition series for revoked partitions.

pub fn rebalance_assigned(&self)

Count a rebalance assignment event.

pub fn rebalance_revoked(&self)

Count a rebalance revocation event.

pub fn set_lanes_active(&self, lanes: usize)

Set the number of currently assigned lanes.

Trait Implementations

impl Debug for SourceMetrics

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

Formats the value using the given formatter.