dusk_node/
telemetry.rs

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
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
// This Source Code Form is subject to the terms of the Mozilla Public
// License, v. 2.0. If a copy of the MPL was not distributed with this
// file, You can obtain one at http://mozilla.org/MPL/2.0/.
//
// Copyright (c) DUSK NETWORK. All rights reserved.

use std::net::SocketAddr;
use std::sync::Arc;
use std::time::Duration;

use async_trait::async_trait;
use memory_stats::memory_stats;
use metrics::histogram;
use metrics_exporter_prometheus::PrometheusBuilder;
use tokio::sync::RwLock;
use tokio::time::sleep;

use crate::{database, vm, LongLivedService, Network};

#[derive(Default)]
pub struct TelemetrySrv {
    addr: Option<String>,
}

#[async_trait]
impl<N: Network, DB: database::DB, VM: vm::VMExecution>
    LongLivedService<N, DB, VM> for TelemetrySrv
{
    /// Returns service name.
    fn name(&self) -> &'static str {
        "telemetry"
    }

    /// Initialize and spawn Prometheus Exporter and Recorder
    async fn execute(
        &mut self,
        network: Arc<RwLock<N>>,
        _: Arc<RwLock<DB>>,
        _: Arc<RwLock<VM>>,
    ) -> anyhow::Result<usize> {
        // If PrometheusBuilder Recorder is not enabled then a NOOP
        // (No-overhead) recorder is used by default.
        if let Some(addr) = &self.addr {
            let addr = addr.parse::<SocketAddr>()?;
            let (recorder, exporter) =
                PrometheusBuilder::new().with_http_listener(addr).build()?;
            metrics::set_global_recorder(recorder)?;
            tokio::spawn(exporter);

            loop {
                sleep(Duration::from_secs(5)).await;
                // Record memory stats
                if let Some(usage) = memory_stats() {
                    histogram!("dusk_physical_mem")
                        .record(usage.physical_mem as f64);
                    histogram!("dusk_virtual_mem")
                        .record(usage.virtual_mem as f64);
                }

                // Record number of alive kadcast peers
                let count = network.read().await.alive_nodes_count().await;
                histogram!("dusk_kadcast_peers").record(count as f64);
            }
        }
        Ok(0)
    }
}

impl TelemetrySrv {
    pub fn new(addr: Option<String>) -> Self {
        Self { addr }
    }
}