tycho-network 0.3.3

A peer-to-peer networking library.
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
27
28
29
30
31
32

use metrics::Counter;

#[derive(Default)]
pub(super) enum Metrics {
    Enabled {
        tx: Counter,
        rx: Counter,
    },
    #[default]
    Disabled,
}

impl Metrics {
    pub fn new(name: &'static str, label: &'static str) -> Self {
        Metrics::Enabled {
            tx: metrics::counter!(format!("{name}_tx"), "service" => label),
            rx: metrics::counter!(format!("{name}_rx"), "service" => label),
        }
    }

    pub fn record_tx(&self, value: usize) {
        if let Metrics::Enabled { tx, .. } = self {
            tx.increment(value as u64);
        }
    }

    pub fn record_rx(&self, value: usize) {
        if let Metrics::Enabled { rx, .. } = self {
            rx.increment(value as u64);
        }
    }
}