rskit-stateful 0.2.0-alpha.1

Stateful accumulators with triggers, measurers, and TTL cleanup
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

//! Value measurers for stateful accumulators.

/// Measures the size of accumulated values.
pub trait Measurer<V>: Send + Sync {
    /// Return the measured size for `values`.
    fn measure(&self, values: &[V]) -> usize;
}

/// Counts accumulated items.
#[derive(Debug, Clone, Copy, Default)]
pub struct CountMeasurer;

impl<V> Measurer<V> for CountMeasurer {
    fn measure(&self, values: &[V]) -> usize {
        values.len()
    }
}

/// Measures accumulated byte-like values by total byte length.
#[derive(Debug, Clone, Copy, Default)]
pub struct ByteSizeMeasurer;

impl<V> Measurer<V> for ByteSizeMeasurer
where
    V: AsRef<[u8]>,
{
    fn measure(&self, values: &[V]) -> usize {
        values.iter().map(|value| value.as_ref().len()).sum()
    }
}