malstrom 0.1.0

Malstrom is a distributed, stateful stream processing framework written in Rust.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

//! Malstrom is a framework for building distributed, stateful stream processes.
pub mod channels;
pub mod coordinator;
pub mod errorhandling;
pub mod keyed;
pub mod operators;
pub mod runtime;
pub mod sinks;
pub mod snapshot;
pub mod sources;
pub mod stream;
pub mod types;
pub mod worker;

#[cfg(test)]
pub(crate) mod testing;