diff --git a/src/common/base/src/runtime/metrics/histogram.rs b/src/common/base/src/runtime/metrics/histogram.rs index f0b1bdcf479fa..f5feaad7e55b7 100644 --- a/src/common/base/src/runtime/metrics/histogram.rs +++ b/src/common/base/src/runtime/metrics/histogram.rs @@ -30,13 +30,14 @@ use crate::runtime::metrics::sample::MetricSample; use crate::runtime::metrics::sample::MetricValue; use crate::runtime::metrics::ScopedRegistry; -pub static BUCKET_SECONDS: [f64; 15] = [ - 0.02, 0.05, 0.1, 0.25, 0.5, 1.0, 2.5, 5.0, 10.0, 20.0, 30.0, 60.0, 300.0, 600.0, 1800.0, +pub static BUCKET_SECONDS: [f64; 16] = [ + 0.05, 0.1, 0.25, 0.5, 1.0, 2.5, 5.0, 10.0, 30.0, 60.0, 300.0, 600.0, 1800.0, 3600.0, 7200.0, + 28800.0, ]; -pub static BUCKET_MILLISECONDS: [f64; 15] = [ - 10.0, 50.0, 100.0, 250.0, 500.0, 1000.0, 2500.0, 5000.0, 10000.0, 20000.0, 30000.0, 60000.0, - 300000.0, 600000.0, 1800000.0, +pub static BUCKET_MILLISECONDS: [f64; 16] = [ + 50.0, 100.0, 250.0, 500.0, 1000.0, 2500.0, 5000.0, 10000.0, 30000.0, 60000.0, 300000.0, + 600000.0, 1800000.0, 3600000.0, 7200000.0, 28800000.0, ]; pub static BUCKET_ROWS: [f64; 14] = [ diff --git a/src/common/base/tests/it/metrics/registry.rs b/src/common/base/tests/it/metrics/registry.rs index 38b3417bad3ef..d48f3c3b345e3 100644 --- a/src/common/base/tests/it/metrics/registry.rs +++ b/src/common/base/tests/it/metrics/registry.rs @@ -145,7 +145,7 @@ fn test_tracking_scoped_gauge_metrics() -> Result<()> { fn test_tracking_scoped_histogram_in_seconds_metrics() -> Result<()> { let uniq_metric_name = GlobalUniqName::unique(); let histogram = register_histogram_in_seconds(&uniq_metric_name); - histogram.observe(1801.0); + histogram.observe(28801.0); fn seconds_histogram_value(v: f64) -> Vec { BUCKET_SECONDS @@ -168,7 +168,7 @@ fn test_tracking_scoped_histogram_in_seconds_metrics() -> Result<()> { new_tracking_payload.metrics = Some(scoped_registry.clone()); let _guard = ThreadTracker::tracking(new_tracking_payload); - histogram.observe(1801.0); + histogram.observe(28801.0); assert_contain_metric(GLOBAL_METRICS_REGISTRY.dump_sample()?, MetricSample { name: uniq_metric_name.clone(), @@ -184,7 +184,7 @@ fn test_tracking_scoped_histogram_in_seconds_metrics() -> Result<()> { } // untracking assert - histogram.observe(1801.0); + histogram.observe(28801.0); assert_contain_metric(GLOBAL_METRICS_REGISTRY.dump_sample()?, MetricSample { name: uniq_metric_name.clone(), @@ -205,7 +205,7 @@ fn test_tracking_scoped_histogram_in_seconds_metrics() -> Result<()> { fn test_tracking_scoped_histogram_in_milliseconds_metrics() -> Result<()> { let uniq_metric_name = GlobalUniqName::unique(); let histogram = register_histogram_in_milliseconds(&uniq_metric_name); - histogram.observe(1800001.0); + histogram.observe(28800001.0); fn milliseconds_histogram_value(v: f64) -> Vec { BUCKET_MILLISECONDS @@ -228,7 +228,7 @@ fn test_tracking_scoped_histogram_in_milliseconds_metrics() -> Result<()> { new_tracking_payload.metrics = Some(scoped_registry.clone()); let _guard = ThreadTracker::tracking(new_tracking_payload); - histogram.observe(1800001.0); + histogram.observe(28800001.0); assert_contain_metric(GLOBAL_METRICS_REGISTRY.dump_sample()?, MetricSample { name: uniq_metric_name.clone(), @@ -244,7 +244,7 @@ fn test_tracking_scoped_histogram_in_milliseconds_metrics() -> Result<()> { } // untracking assert - histogram.observe(1800001.0); + histogram.observe(28800001.0); assert_contain_metric(GLOBAL_METRICS_REGISTRY.dump_sample()?, MetricSample { name: uniq_metric_name.clone(),