Struct SinkShardMetrics 

pub struct SinkShardMetrics { /* private fields */ }

Sink-shard handles (etl_sink_*), one struct per shard worker.

Implementations

impl SinkShardMetrics

pub fn new( labels: &ComponentLabels, shard: u32, replicas: &[String], e2e_basis: E2eBasis, ) -> SinkShardMetrics

Resolve all handles for one shard. replicas are display names used as the replica label (bounded by cluster topology). e2e_basis selects the time base for etl_e2e_latency_seconds (see docs/METRICS.md).

Call after install: handles bind to the recorder present at construction, and a handle built before the exporter exists silently records into the void.

pub fn e2e_observed(&self, ingest_age: Duration, oldest_event_ms: i64)

Observe end-to-end latency for one durably written batch, from its oldest record. ingest_age is time since that record entered the terminal stage; oldest_event_ms is its source event time. The configured basis picks which one lands in the histogram (event basis falls back to ingest when no event time was available).

pub fn flushed(&self, reason: FlushReason, rows: u64, bytes: u64, d: Duration)

Record one durably acknowledged flush.

pub fn retries(&self, n: u64)

Count flush attempts beyond the first.

pub fn errors(&self, class: ErrorClass, n: u64)

Count write errors of one taxonomy class.

pub fn set_inflight(&self, batches: usize)

Set the number of sealed batches currently in flight.

pub fn set_replica_healthy(&self, replica: usize, healthy: bool)

Mark one replica healthy (circuit closed) or quarantined (open).

pub fn breaker_opened(&self, replica: usize)

Count a circuit-breaker open transition on one replica.

pub fn abandoned(&self, n: u64)

Count batches abandoned at the drain deadline.

Trait Implementations

impl Debug for SinkShardMetrics

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

Formats the value using the given formatter.