tiny-counter 0.1.0

Track event counts across time windows with fixed memory and fast queries
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
45
46
47
48

use crate::{formatter::Formatter, Result, SingleEventCounter};

/// Bincode serialization format.
///
/// Compact binary format, fast serialization/deserialization.
#[derive(Debug, Clone, Copy)]
pub struct BincodeFormat;

impl Formatter for BincodeFormat {
    fn serialize(&self, value: &SingleEventCounter) -> Result<Vec<u8>> {
        bincode::serialize(value).map_err(|e| crate::Error::Serialization(e.to_string()))
    }

    fn deserialize(&self, bytes: &[u8]) -> Result<SingleEventCounter> {
        bincode::deserialize(bytes).map_err(|e| crate::Error::Serialization(e.to_string()))
    }

    fn extension(&self) -> &'static str {
        ".bin"
    }
}

#[cfg(test)]
mod tests {
    use super::*;
    use crate::{EventCounterConfig, SingleEventCounter};
    use chrono::Utc;

    #[test]
    fn test_bincode_roundtrip() {
        let formatter = BincodeFormat;
        let now = Utc::now();
        let config = EventCounterConfig::default();
        let counter = config.create_counter(now);

        let bytes = formatter.serialize(&counter).unwrap();
        let decoded: SingleEventCounter = formatter.deserialize(&bytes).unwrap();

        // Verify structure matches
        assert_eq!(decoded.intervals().len(), counter.intervals().len());
    }

    #[test]
    fn test_bincode_extension() {
        let formatter = BincodeFormat;
        assert_eq!(formatter.extension(), ".bin");
    }
}