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

use crate::{config, Error};

pub struct WindowBuffer<T> {
    buffer: dasp_ring_buffer::Bounded<Vec<T>>,
}

impl<T> TryFrom<&config::FilterWindowConfig> for WindowBuffer<T>
where
    T: Default + Copy,
{
    type Error = Error;

    fn try_from(config: &config::FilterWindowConfig) -> std::result::Result<Self, Self::Error> {
        if config.window_size == 0 {
            return Err(Error(String::from("'window_size' cannot be 0.")));
        }
        let buffer =
            dasp_ring_buffer::Bounded::from(vec![T::default(); config.window_size as usize]);
        Ok(Self { buffer })
    }
}

impl<T> WindowBuffer<T>
where
    T: Copy + Default,
{
    pub fn push(&mut self, data: T) {
        self.buffer.push(data);
    }

    pub fn iter(&self) -> std::iter::Chain<std::slice::Iter<'_, T>, std::slice::Iter<'_, T>> {
        self.buffer.iter()
    }
}