path: root/src/rpc/metrics.rs

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(),
		}
	}
}