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

//! Types and traits used accross JetStream
mod data;
mod key;
mod message;
mod operator_partitioner;
mod time;

pub use data::{Data, MaybeData, NoData};
pub use key::{Key, MaybeKey, NoKey};
pub use message::{DataMessage, Message, RescaleMessage, SuspendMarker};
pub use operator_partitioner::{OperatorId, OperatorPartitioner};
pub use time::{MaybeTime, NoTime, Timestamp};

/// Uniquely identifies a worker in a JetStream cluster
pub type WorkerId = u64;