From 8036d27e6f6bc1783197b79f29c9dea043c253ae Mon Sep 17 00:00:00 2001 From: Nils Andreas Svee Date: Mon, 13 Apr 2026 18:52:33 +0700 Subject: [PATCH] feat(metrics): track and report dropped metric counts --- src/metrics.rs | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/src/metrics.rs b/src/metrics.rs index 87ef7e0..a6cc4a6 100644 --- a/src/metrics.rs +++ b/src/metrics.rs @@ -189,6 +189,11 @@ impl Metrics { match self.metrics_rx.recv_timeout(timeout) { Ok(metric) => batch.push(metric), Err(RecvTimeoutError::Timeout) => { + let dropped = self.metrics_dropped.swap(0, Ordering::Relaxed); + if dropped > 0 { + let ts = Time::new(ClockId::Realtime).as_nanos(); + batch.push((Metric::Dropped { count: dropped }, ts)); + } if !batch.is_empty() { self.flush(&mut transport, &batch, host_tag); batch.clear();