reth_db_api/
database_metrics.rs

1use metrics::{counter, gauge, histogram, Label};
2use std::sync::Arc;
3
4/// Represents a type that can report metrics, used mainly with the database. The `report_metrics`
5/// method can be used as a prometheus hook.
6pub trait DatabaseMetrics {
7    /// Reports metrics for the database.
8    fn report_metrics(&self) {
9        for (name, value, labels) in self.gauge_metrics() {
10            gauge!(name, labels).set(value);
11        }
12
13        for (name, value, labels) in self.counter_metrics() {
14            counter!(name, labels).increment(value);
15        }
16
17        for (name, value, labels) in self.histogram_metrics() {
18            histogram!(name, labels).record(value);
19        }
20    }
21
22    /// Returns a list of [Gauge](metrics::Gauge) metrics for the database.
23    fn gauge_metrics(&self) -> Vec<(&'static str, f64, Vec<Label>)> {
24        vec![]
25    }
26
27    /// Returns a list of [Counter](metrics::Counter) metrics for the database.
28    fn counter_metrics(&self) -> Vec<(&'static str, u64, Vec<Label>)> {
29        vec![]
30    }
31
32    /// Returns a list of [Histogram](metrics::Histogram) metrics for the database.
33    fn histogram_metrics(&self) -> Vec<(&'static str, f64, Vec<Label>)> {
34        vec![]
35    }
36}
37
38impl<DB: DatabaseMetrics> DatabaseMetrics for Arc<DB> {
39    fn report_metrics(&self) {
40        <DB as DatabaseMetrics>::report_metrics(self)
41    }
42
43    fn gauge_metrics(&self) -> Vec<(&'static str, f64, Vec<Label>)> {
44        <DB as DatabaseMetrics>::gauge_metrics(self)
45    }
46
47    fn counter_metrics(&self) -> Vec<(&'static str, u64, Vec<Label>)> {
48        <DB as DatabaseMetrics>::counter_metrics(self)
49    }
50
51    fn histogram_metrics(&self) -> Vec<(&'static str, f64, Vec<Label>)> {
52        <DB as DatabaseMetrics>::histogram_metrics(self)
53    }
54}
reth_db_api/database_metrics.rs

reth_db_api/
database_metrics.rs
