Module erdos::dataflow

Expand description

Functions and structures for building an ERDOS application.

Re-exports

pub use deadlines::TimestampDeadline;

pub use message::Data;

pub use message::Message;

pub use message::TimestampedData;

pub use operator::OperatorConfig;

pub use state::AppendableState;

pub use state::State;

pub use stream::Stream;

pub use time::Timestamp;

Library of generic operators for building ERDOS applications.

Structures and traits for states added to streams.

Streams are used to send data between operators.

Enables loops in the dataflow.

A ReadStream allows operators to pull Messages from a stream.

A WriteStream allows operators to send data to other operators.