[−][src]Module erdos::dataflow
Re-exports
pub use crate::dataflow::message::Data; |
pub use crate::dataflow::message::Message; |
pub use crate::dataflow::message::Timestamp; |
pub use crate::dataflow::message::TimestampedData; |
pub use crate::dataflow::operator::OperatorConfig; |
pub use crate::dataflow::operator::OperatorT; |
pub use crate::dataflow::stream::EventMakerT; |
pub use crate::dataflow::stream::LoopStream; |
pub use crate::dataflow::stream::ReadStream; |
pub use crate::dataflow::stream::ReadStreamT; |
pub use crate::dataflow::stream::StatefulReadStream; |
pub use crate::dataflow::stream::WriteStream; |
Modules
| callback_builder | Callback Builders for Multiple Streams |
| graph | |
| message | |
| operator | |
| operators | |
| stream |
Enums
| WriteStreamError | Error raised by the WriteStream layer. |
Traits
| State | Trait that must be implemented by stream state structs. |