Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Merge pull request #6702 from influxdata/dom/persist-enqueue-durations 

refactor: appropriate queue wait histogram buckets
pull/24376/head
Dom 2023-01-25 15:49:14 +00:00 committed by GitHub
parent 8ee6c1ec68 df87ca3f17
commit 7c7d737d0e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 16 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
ingester2/src/persist/handle.rs
View File

@ -1,9 +1,9 @@
use std::sync::Arc;
use std::{sync::Arc, time::Duration};
use async_trait::async_trait;
use iox_catalog::interface::Catalog;
use iox_query::{exec::Executor, QueryChunkMeta};
use metric::{DurationHistogram, U64Counter, U64Gauge};
use metric::{DurationHistogram, DurationHistogramOptions, U64Counter, U64Gauge, DURATION_MAX};
use observability_deps::tracing::*;
use parking_lot::Mutex;
use parquet_file::storage::ParquetStorage;
@ -201,9 +201,22 @@ impl PersistHandle {
)
.recorder(&[]);
let queue_duration = metrics
.register_metric::<DurationHistogram>(
.register_metric_with_options::<DurationHistogram, _>(
"ingester_persist_enqueue_duration",
"the distribution of duration a persist job spent enqueued, waiting to be processed in seconds",
|| DurationHistogramOptions::new([
Duration::from_millis(500),
Duration::from_secs(1),
Duration::from_secs(2),
Duration::from_secs(4),
Duration::from_secs(8),
Duration::from_secs(16),
Duration::from_secs(32),
Duration::from_secs(64),
Duration::from_secs(128),
Duration::from_secs(256),
DURATION_MAX,
])
)
.recorder(&[]);