minmon 0.13.0

An opinionated minimal monitoring and alarming tool
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
36
37
38
39
40
41
42
43
44

use crate::{config, measurement, Error, Result};

mod average;
mod peak;
mod sum;
use average::Average;
use peak::Peak;
use sum::Sum;

pub trait Filter<T>: Send + Sync
where
    T: measurement::Measurement,
{
    fn filter(&mut self, data: T) -> T;

    fn error(&mut self);
}

pub trait FilterFactory {
    fn filter_factory(filter_config: &config::Filter) -> Result<Box<dyn Filter<Self>>>;
}

macro_rules! make_factory {
    ($T:ty, $( $U:ident ),*) => (
        impl FilterFactory for $T {
            fn filter_factory(filter_config: &config::Filter) -> Result<Box<dyn Filter<Self>>> {
                #[allow(unreachable_patterns)]
                match filter_config {
                    $(config::Filter::$U(config) => {
                        Ok(Box::new($U::<$T>::try_from(config)?))
                    },)*
                    _ => Err(Error(String::from("Filter not supported for data type."))),
                }
            }
        }
    )
}
make_factory!(measurement::BinaryState,);
make_factory!(measurement::DataSize, Average, Peak, Sum);
make_factory!(measurement::Integer, Average, Peak, Sum);
make_factory!(measurement::Level, Average, Peak);
make_factory!(measurement::StatusCode,);
#[cfg(feature = "sensors")]
make_factory!(measurement::Temperature, Average, Peak);