flowscope 0.12.0

Passive flow & session tracking for packet capture (runtime-free, cross-platform)
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

//! `flowscope::aggregate` — distribution / quantile primitives.
//!
//! Two small types every observability example reinvents:
//!
//! - [`Histogram`] — explicit-bucket counter with `record` /
//!   `quantile` / `merge`. For "distribution of X" reports (flow
//!   durations, packet sizes, response times).
//! - [`Percentile`] — t-digest-style streaming quantile estimator
//!   for unbounded streams. Wraps the `tdigest` crate.
//!
//! Use [`Histogram`] when you know the buckets up front and want
//! exact counts per bucket. Use [`Percentile`] for unbounded
//! streams where memorising every sample isn't feasible and you
//! only need quantile reads at the tail (p95, p99, p999).
//!
//! ```
//! use flowscope::aggregate::Histogram;
//!
//! // Flow-duration buckets in seconds, log-spaced 100 ms → 1 h.
//! let mut h = Histogram::log_spaced(0.1, 3600.0, 6);
//! for d in [0.5, 1.2, 8.0, 45.0, 200.0] {
//!     h.record(d);
//! }
//! assert_eq!(h.samples(), 5);
//! let _p95 = h.quantile(0.95);
//! ```
//!
//! New in 0.10.0 (plan 102 sub-B).

mod histogram;
mod percentile;

pub use histogram::{Histogram, HistogramError};
pub use percentile::Percentile;