malstrom 0.1.0

Malstrom is a distributed, stateful stream processing framework written in Rust.
Documentation 
1
2
3
4
5
6
7
8

//! Sources for reading data
mod single_iterator;
mod stateful;
mod stateless;

pub use single_iterator::SingleIteratorSource;
pub use stateful::{StatefulSource, StatefulSourceImpl, StatefulSourcePartition};
pub use stateless::{StatelessSource, StatelessSourceImpl, StatelessSourcePartition};