From 3abd46010cefea8f681762b70b2c4d64f3f89215 Mon Sep 17 00:00:00 2001
From: HaoranYi <haoran.yi@gmail.com>
Date: Mon, 25 Apr 2022 19:18:38 -0500
Subject: [PATCH] Report metric command queue size (#24661)

* report metric command queue size

* rename buffered_points
---
 metrics/src/metrics.rs | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/metrics/src/metrics.rs b/metrics/src/metrics.rs
index 1ce35c2ce..b116d96ba 100644
--- a/metrics/src/metrics.rs
+++ b/metrics/src/metrics.rs
@@ -186,6 +186,7 @@ impl MetricsAgent {
         max_points: usize,
         max_points_per_sec: usize,
         last_write_time: Instant,
+        points_buffered: usize,
     ) {
         if points.is_empty() {
             return;
@@ -208,6 +209,7 @@ impl MetricsAgent {
                 .add_field_i64("points_written", points_written as i64)
                 .add_field_i64("num_points", num_points as i64)
                 .add_field_i64("points_lost", (num_points - points_written) as i64)
+                .add_field_i64("points_buffered", points_buffered as i64)
                 .add_field_i64(
                     "secs_since_last_write",
                     now.duration_since(last_write_time).as_secs() as i64,
@@ -239,6 +241,7 @@ impl MetricsAgent {
                             max_points,
                             max_points_per_sec,
                             last_write_time,
+                            receiver.len(),
                         );
                         last_write_time = Instant::now();
                         barrier.wait();
@@ -281,6 +284,7 @@ impl MetricsAgent {
                     max_points,
                     max_points_per_sec,
                     last_write_time,
+                    receiver.len(),
                 );
                 last_write_time = now;
             }