Report metric command queue size (#24661)
* report metric command queue size * rename buffered_points
This commit is contained in:
parent
9044cd7179
commit
3abd46010c
|
@ -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;
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue