zksync_eth_watch 0.1.0

ZKsync Ethereum watcher
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

//! Metrics for Ethereum watcher.

use std::time::Duration;

use vise::{Buckets, Counter, EncodeLabelSet, EncodeLabelValue, Family, Histogram, Metrics};

#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash, EncodeLabelValue, EncodeLabelSet)]
#[metrics(label = "stage", rename_all = "snake_case")]
pub(super) enum PollStage {
    Request,
    PersistL1Txs,
    PersistUpgrades,
}

#[derive(Debug, Metrics)]
#[metrics(prefix = "server_eth_watch")]
pub(super) struct EthWatcherMetrics {
    /// Number of times Ethereum was polled.
    pub eth_poll: Counter,
    /// Latency of polling and processing events split by stage.
    #[metrics(buckets = Buckets::LATENCIES)]
    pub poll_eth_node: Family<PollStage, Histogram<Duration>>,
}

#[vise::register]
pub(super) static METRICS: vise::Global<EthWatcherMetrics> = vise::Global::new();