uwheel 0.4.0

Embeddable Aggregate Management System for Streams and Queries
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 core::{cell::Cell, fmt};
use uwheel_stats::Sketch;

/// Stats for [AggregationWheel]
#[cfg_attr(feature = "serde", derive(serde::Deserialize, serde::Serialize))]
#[derive(Clone, Default)]
pub struct Stats {
    pub combine_ops: u64,
    pub combine_range: Sketch,
    pub insert: Sketch,
    pub total_access: Cell<u64>,
    pub scans: Cell<u64>,
}
impl Stats {
    pub fn add_combine_ops(&mut self, ops: u64) {
        self.combine_ops += ops;
    }
    pub fn add_scans(&self, scans: u64) {
        self.scans.set(self.scans.get() + scans);
    }
    pub fn bump_total(&self) {
        self.total_access.set(self.total_access.get() + 1);
    }
}

impl core::fmt::Debug for Stats {
    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
        f.debug_struct("HAW Stats")
            .field("combine ops", &self.combine_ops)
            .field("scans", &self.scans.get())
            .field("combine_range", &self.combine_range.percentiles())
            .field("total access", &self.total_access.get())
            .finish()
    }
}