Crate mz_storage
source · [−]Expand description
Driver for timely/differential dataflow.
Re-exports
pub use boundary::tcp_boundary;pub use decode::metrics::DecodeMetrics;Modules
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.
Structs
Configures a dataflow server.
A boundary implementation that panics on use.
A handle to a running dataflow server.
Traits
A type that can replay specific sources
A type that can capture a specific source.
Functions
Initiates a timely dataflow computation, processing materialized commands.