below-model 0.9.0

Model crate for below
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
33
34
35

use anyhow::Result;
use async_trait::async_trait;
use slog::error;
use tc::TcStats;

use crate::collector_plugin::AsyncCollectorPlugin;

pub type SampleType = TcStats;

pub struct TcStatsCollectorPlugin {
    logger: slog::Logger,
}

impl TcStatsCollectorPlugin {
    pub fn new(logger: slog::Logger) -> Result<Self> {
        Ok(Self { logger })
    }
}

#[async_trait]
impl AsyncCollectorPlugin for TcStatsCollectorPlugin {
    type T = TcStats;

    async fn try_collect(&mut self) -> Result<Option<SampleType>> {
        let stats = match tc::tc_stats() {
            Ok(tc_stats) => Some(tc_stats),
            Err(e) => {
                error!(self.logger, "{:#}", e);
                Default::default()
            }
        };

        Ok(stats)
    }
}