forked from Deuxfleurs/garage
56 lines
1.7 KiB
Rust
56 lines
1.7 KiB
Rust
|
use std::sync::Arc;
|
||
|
|
|
||
|
|
use opentelemetry::{global, metrics::*};
|
||
|
|
use tokio::sync::Semaphore;
|
||
|
|
|
||
|
|
/// TableMetrics reference all counter used for metrics
|
||
|
|
pub struct RpcMetrics {
|
||
|
|
pub(crate) _rpc_available_permits: ValueObserver<u64>,
|
||
|
|
|
||
|
|
pub(crate) rpc_counter: Counter<u64>,
|
||
|
|
pub(crate) rpc_timeout_counter: Counter<u64>,
|
||
|
|
pub(crate) rpc_netapp_error_counter: Counter<u64>,
|
||
|
|
pub(crate) rpc_garage_error_counter: Counter<u64>,
|
||
|
|
|
||
|
|
pub(crate) rpc_duration: ValueRecorder<f64>,
|
||
|
|
pub(crate) rpc_queueing_time: ValueRecorder<f64>,
|
||
|
|
}
|
||
|
|
impl RpcMetrics {
|
||
|
|
pub fn new(sem: Arc<Semaphore>) -> Self {
|
||
|
|
let meter = global::meter("garage_rpc");
|
||
|
|
RpcMetrics {
|
||
|
|
_rpc_available_permits: meter
|
||
|
|
.u64_value_observer("rpc.available_permits", move |observer| {
|
||
|
|
observer.observe(sem.available_permits() as u64, &[])
|
||
|
|
})
|
||
|
|
.with_description("Number of available RPC permits")
|
||
|
|
.init(),
|
||
|
|
|
||
|
|
rpc_counter: meter
|
||
|
|
.u64_counter("rpc.request_counter")
|
||
|
|
.with_description("Number of RPC requests emitted")
|
||
|
|
.init(),
|
||
|
|
rpc_timeout_counter: meter
|
||
|
|
.u64_counter("rpc.timeout_counter")
|
||
|
|
.with_description("Number of RPC timeouts")
|
||
|
|
.init(),
|
||
|
|
rpc_netapp_error_counter: meter
|
||
|
|
.u64_counter("rpc.netapp_error_counter")
|
||
|
|
.with_description("Number of communication errors (errors in the Netapp library)")
|
||
|
|
.init(),
|
||
|
|
rpc_garage_error_counter: meter
|
||
|
|
.u64_counter("rpc.garage_error_counter")
|
||
|
|
.with_description("Number of RPC errors (errors happening when handling the RPC)")
|
||
|
|
.init(),
|
||
|
|
rpc_duration: meter
|
||
|
|
.f64_value_recorder("rpc.duration")
|
||
|
|
.with_description("Duration of RPCs")
|
||
|
|
.init(),
|
||
|
|
rpc_queueing_time: meter
|
||
|
|
.f64_value_recorder("rpc.queueing_time")
|
||
|
|
.with_description("Time RPC requests were queued for before being sent")
|
||
|
|
.init(),
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|