gsadmin/garage
1
0
Fork 0
mirror of https://github.com/deuxfleurs-org/garage.git synced 2026-08-10 22:36:53 +00:00
Code Issues Packages Projects Releases Wiki Activity

add an opentelemetry metric

Browse Source
This commit is contained in:
Quentin Dufour
2025-04-30 07:24:20 +02:00
parent 7fddf0af9c
commit 60b3d28f93
2 changed files with 19 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/table/data.rs
+4 -3
View File
@@ -21,9 +21,9 @@ use crate::replication::*;
use crate::schema::*;
use crate::util::*;
pub(crate) const MERKLE_SLEEP_INITIAL: Duration = Duration::from_micros(100);
pub(crate) const MERKLE_SLEEP_MAX: Duration = Duration::from_secs(30);
pub(crate) const MERKLE_SLEEP_ADD_DECREASE: Duration = Duration::from_micros(100);
pub(crate) const MERKLE_SLEEP_INITIAL: Duration = Duration::from_micros(10);
pub(crate) const MERKLE_SLEEP_MAX: Duration = Duration::from_secs(2);
pub(crate) const MERKLE_SLEEP_ADD_DECREASE: Duration = Duration::from_micros(10);
pub(crate) const MERKLE_SLEEP_MULT_INCREASE: f32 = 1.2;
pub struct TableData<F: TableSchema, R: TableReplication> {
@@ -75,6 +75,7 @@ impl<F: TableSchema, R: TableReplication> TableData<F, R> {
store.clone(),
merkle_tree.clone(),
merkle_todo.clone(),
merkle_todo_sleep.clone(),
gc_todo.clone(),
);
src/table/metrics.rs
+15
View File
@@ -1,4 +1,5 @@
use opentelemetry::{global, metrics::*, KeyValue};
use std::sync::{Arc, Mutex};
use garage_db as db;
@@ -7,6 +8,7 @@ pub struct TableMetrics {
pub(crate) _table_size: ValueObserver<u64>,
pub(crate) _merkle_tree_size: ValueObserver<u64>,
pub(crate) _merkle_todo_len: ValueObserver<u64>,
pub(crate) _merkle_todo_sleep_ms: ValueObserver<f64>,
pub(crate) _gc_todo_len: ValueObserver<u64>,
pub(crate) get_request_counter: BoundCounter<u64>,
@@ -26,6 +28,7 @@ impl TableMetrics {
store: db::Tree,
merkle_tree: db::Tree,
merkle_todo: db::Tree,
merkle_todo_sleep: Arc<Mutex<std::time::Duration>>,
gc_todo: db::Tree,
) -> Self {
let meter = global::meter(table_name);
@@ -72,6 +75,18 @@ impl TableMetrics {
)
.with_description("Merkle tree updater TODO queue length")
.init(),
_merkle_todo_sleep_ms: meter
.f64_value_observer(
"table.merkle_updater_todo_queue_backpressure_ms",
move |observer| {
let bp_ref = merkle_todo_sleep.clone();
let bp_val = bp_ref.lock().unwrap();
let bp_millis: f64 = bp_val.as_micros() as f64 / 1000.0f64;
observer.observe(bp_millis, &[KeyValue::new("table_name", table_name)])
}
)
.with_description("Merkle tree updater TODO sleep backpressure to apply in ms")
.init(),
_gc_todo_len: meter
.u64_value_observer(
"table.gc_todo_queue_length",