Crate dataflow[−][src]
Driver for timely/differential dataflow.
Modules
| logging | Logging dataflows for events generated by various subsystems. |
| source | Types related to the creation of dataflow sources. |
Structs
| Config | Configures a dataflow server. |
| FilterPlan | Predicates partitioned into temporal and non-temporal. |
| WorkerFeedbackWithMeta | Information from timely dataflow workers. |
Enums
| CacheMessage | All data and metadata messages that can be sent by dataflow workers or coordinator to the cacher thread. |
| SequencedCommand | Explicit instructions for timely dataflow workers. |
| WorkerFeedback | Responses the worker can provide back to the coordinator. |
Functions
| serve | Initiates a timely dataflow computation, processing materialized commands. |