Add batcher_flush_size histogram

Kuadrant · May 14, 2024 · dd73fc3 · dd73fc3
1 parent bd16d65
commit dd73fc3
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/limitador/src/storage/redis/counters_cache.rs b/limitador/src/storage/redis/counters_cache.rs
@@ -3,7 +3,7 @@ use crate::storage::atomic_expiring_value::AtomicExpiringValue;
 use crate::storage::redis::DEFAULT_MAX_CACHED_COUNTERS;
 use dashmap::mapref::entry::Entry;
 use dashmap::DashMap;
-use metrics::gauge;
+use metrics::{gauge, histogram};
 use moka::sync::Cache;
 use std::collections::HashMap;
 use std::future::Future;
@@ -186,6 +186,7 @@ impl Batcher {
                     let value = self.updates.get(counter).unwrap().clone();
                     result.insert(counter.clone(), value);
                 }
+                histogram!("batcher_flush_size").record(result.len() as f64);
                 let result = consumer(result).await;
                 batch.iter().for_each(|counter| {
                     self.updates