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

//! # Coordinator
//!
//! The [Coordinator] is the brain of any Malstrom job and controls the job lifecycle.
//! It is responsible for triggering job start, snapshots and reconfigurations.

#[allow(clippy::module_inception)] // I can't come up with a better name
mod coordinator;
pub use coordinator::{
    Coordinator, CoordinatorApi, CoordinatorExecutionError, CoordinatorRequestError,
    CoordinatorStatus,
};
mod communication;
mod state;
pub(crate) mod types;
mod watchmap;