Materialize’s storage layer.
pub use decode::metrics::DecodeMetrics;
pub use server::serve;
pub use server::Config;
pub use server::Server;
This module provides functions that build decoding pipelines from raw source streams.
Types for cluster-internal control messages that can be broadcast to all workers from individual operators/workers.
Renders ingestions and exports into timely dataflow
An interactive dataflow server.
Moving data to external systems
Types related to the creation of dataflow raw sources.
Helpers for managing storage statistics.
Worker-local state for storage timely instances.