Expand description

Driver for timely/differential dataflow.


pub use boundary::tcp_boundary;
pub use decode::metrics::DecodeMetrics;


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.

server 🔒

An interactive dataflow server.

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.