Crate mz_storage

Materialize’s storage layer.

Re-exports

pub use server::serve;

Modules

decode

This module provides functions that build decoding pipelines from raw source streams.

healthcheck 🔒

Healthcheck common

internal_control

Types for cluster-internal control messages that can be broadcast to all workers from individual operators/workers.

metrics

Metrics for all things storage.

render

Renders ingestions and exports into timely dataflow

server

An interactive dataflow server.

sink

Moving data to external systems

source

Types related to the creation of dataflow raw sources.

statistics

Helpers for managing storage statistics.

storage_state

Worker-local state for storage timely instances.

upsert 🔒

upsert_continual_feedback 🔒

Implementation of feedback UPSERT operator and associated helpers. See upsert_inner for a description of how the operator works and why.