coerce 0.8.11

Async actor runtime and distributed systems framework
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

pub const METRIC_NETWORK_BYTES_RECV: &str = "coerce_network_bytes_recv";
pub const METRIC_NETWORK_BYTES_SENT: &str = "coerce_network_bytes_sent";

pub const LABEL_SRC_ADDR: &str = "src_addr";
pub const LABEL_DEST_ADDR: &str = "dest_addr";

pub struct NetworkMetrics;

impl NetworkMetrics {
    #[inline]
    pub fn incr_bytes_received(len: u64, src_addr: &str) {
        #[cfg(feature = "metrics")]
        counter!(
            METRIC_NETWORK_BYTES_RECV,
            len,
            LABEL_SRC_ADDR => src_addr.to_owned()
        );
    }

    #[inline]
    pub fn incr_bytes_sent(len: u64, dest_addr: &str) {
        #[cfg(feature = "metrics")]
        counter!(
            METRIC_NETWORK_BYTES_SENT,
            len,
            LABEL_DEST_ADDR => dest_addr.to_owned()
        );
    }
}