Expand description

Materialize’s storage layer.


pub use decode::metrics::DecodeMetrics;


A controller that provides an interface to the storage layer.
This module provides functions that build decoding pipelines from raw source streams.
The communication protocol between the storaged server and the storage controller
Renders a plan into a timely/differential dataflow computation.
Moving data to external systems
Types related to the creation of dataflow raw sources.
Worker-local state for storage timely instances.


Configures a dataflow server.
A handle to a running dataflow server.


Initiates a timely dataflow computation, processing storage commands.