Driver for timely/differential dataflow.
Types and traits for communicating definite data from storage to compute.
This module provides functions that build decoding pipelines from raw source streams.
Renders a plan into a timely/differential dataflow computation.
Types related to the creation of dataflow raw sources.
Worker-local state for storage timely instances.
Configures a dataflow server.
A boundary implementation that panics on use.
A handle to a running dataflow server.
A type that can replay specific sources
A type that can capture a specific source.
Initiates a timely dataflow computation, processing materialized commands.