reth_trie_parallel/
metrics.rs

1use crate::stats::ParallelTrieStats;
2use metrics::Histogram;
3use reth_metrics::Metrics;
4use reth_trie::metrics::{TrieRootMetrics, TrieType};
5
6/// Parallel state root metrics.
7#[derive(Debug)]
8pub struct ParallelStateRootMetrics {
9    /// State trie metrics.
10    pub state_trie: TrieRootMetrics,
11    /// Parallel trie metrics.
12    pub parallel: ParallelTrieMetrics,
13    /// Storage trie metrics.
14    pub storage_trie: TrieRootMetrics,
15}
16
17impl Default for ParallelStateRootMetrics {
18    fn default() -> Self {
19        Self {
20            state_trie: TrieRootMetrics::new(TrieType::State),
21            parallel: ParallelTrieMetrics::default(),
22            storage_trie: TrieRootMetrics::new(TrieType::Storage),
23        }
24    }
25}
26
27impl ParallelStateRootMetrics {
28    /// Record state trie metrics
29    pub fn record_state_trie(&self, stats: ParallelTrieStats) {
30        self.state_trie.record(stats.trie_stats());
31        self.parallel.precomputed_storage_roots.record(stats.precomputed_storage_roots() as f64);
32        self.parallel.missed_leaves.record(stats.missed_leaves() as f64);
33    }
34}
35
36/// Parallel state root metrics.
37#[derive(Metrics)]
38#[metrics(scope = "trie_parallel")]
39pub struct ParallelTrieMetrics {
40    /// The number of storage roots computed in parallel.
41    pub precomputed_storage_roots: Histogram,
42    /// The number of leaves for which we did not pre-compute the storage roots.
43    pub missed_leaves: Histogram,
44}
reth_trie_parallel/metrics.rs

reth_trie_parallel/
metrics.rs
