Expand description

The types for the dataflow crate.

These are extracted into their own crate so that crates that only depend on the interface of the dataflow crate, and not its implementation, can avoid the dependency, as the dataflow crate is very slow to compile.

Re-exports

pub use plan::Plan;

Modules

Traits and types for controller of the dataflow subsystem.

Connection types.

An explicit representation of a rendering plan for provided dataflows.

Nested message and enum types in ProtoDataflowDescription.

Nested message and enum types in ProtoDataflowError.

Nested message and enum types in ProtoDecodeError.

Nested message and enum types in ProtoPeekResponse.

Nested message and enum types in ProtoSourceErrorDetails.

Nested message and enum types in ProtoTailBatch.

Nested message and enum types in ProtoTailResponse.

Types and traits related to reporting changing collections out of dataflow.

Types and traits related to the introduction of changing collections into dataflow.

Structs

An association of a global identifier to an expression.

A description of a dataflow to construct and results to surface.

An Explanation facilitates pretty-printing of the parts of a DataflowDescription that are relevant to dataflow rendering.

An index storing processed updates so they can be queried or reused in other computations

In-place restrictions that can be made to rows.

Per-source construction arguments.

A description of an instantiation of a source.

A batch of updates for the interval [lower, upper).

Information used when determining the timestamp for a query.

A batch of updates to be fed to a local input

Enums

The response from a Peek.

Various responses that can be communicated about the progress of a TAIL command.

Traits

Provides cleaner access to the populate_client_config implementation for structs.

Functions

Propagates appropriate configuration options from kafka_connection and options into config, ignoring any options identified in drop_option_keys.

Type Definitions

A commonly used name for dataflows contain MIR expressions.

Type alias for source subscriptions, (dataflow_id, source_id).