malstrom 0.1.0

Malstrom is a distributed, stateful stream processing framework written in Rust.
Documentation
1
2
3
4
5
6
7
mod assign_timestamps;
mod generate_epochs;
mod inspect_frontier;
mod util;
pub use self::generate_epochs::{limit_out_of_orderness, GenerateEpochs, NeedsEpochs};
pub use self::inspect_frontier::InspectFrontier;
pub use assign_timestamps::AssignTimestamps;