[][src]Crate dataflow

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

BroadcastToken

A comm::broadcast::Token that permits broadcasting commands to the Timely workers.

Config

Configures a dataflow server.

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.