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

//! Runtimes determine where Malstrom jobs are executed. Runtimes provide the necessary
//! infrastructure and communication channels for Malstrom to run jobs.
pub mod communication;
pub(crate) mod runtime_flavor;
pub mod threaded;

pub use communication::{BiCommunicationClient, CommunicationClient, OperatorOperatorComm};
pub use runtime_flavor::{CommunicationError, RuntimeFlavor};
pub use threaded::{MultiThreadRuntime, SingleThreadRuntime, SingleThreadRuntimeFlavor};