Expand description
Structured communication between timely dataflow operators.
Modules§
- pact
- Parallelization contracts, describing how data must be exchanged between operators. Parallelization contracts, describing requirements for data movement along dataflow edges.
- pullers
- A collection of types that may be pulled from.
- pushers
- A collection of types that may be pushed at.
Structs§
- Message
- A serializable representation of timestamped data.
Traits§
- Container
Bytes - A container-oriented version of
Bytesablethat can be implemented here forVec<T>and other containers.