scepter 0.1.5

Composable primitives for planet-scale time-series routing, indexing, and aggregation.
Documentation
1
2
3
4
5
6
7
8
9
10
11
//! Time-bucketed collection aggregation primitives.

mod bucketed;
mod error;
mod reducer;
mod window;

pub use bucketed::BucketedAggregator;
pub use error::CollectionError;
pub use reducer::{MaxReducer, MergeReducer, MinReducer, Reducer, SumReducer};
pub use window::{AdmissionWindow, DeltaPoint, FinalizedBucket};