Crate mz_storage_controller

Implementation of the storage controller trait.

Modules

collection_mgmt 🔒

Tokio tasks (and support machinery) for maintaining storage-managed collections.

history 🔒

A reducible history of storage commands.

instance 🔒

A controller for a storage instance.

persist_handles 🔒

A tokio tasks (and support machinery) for dealing with the persist handles that the storage controller needs to hold.

rtr 🔒

Implementation of real-time recency.

statistics 🔒

A tokio task (and support machinery) for producing storage statistics.

Structs

CollectionState 🔒

State maintained about individual collections.

Controller

A storage controller for a storage instance.

IngestionState 🔒

State maintained about ingestions and ingestion exports

PendingOneshotIngestion 🔒

StatusHistoryDesc 🔒

A description of a status history collection.

Enums

CollectionStateExtra 🔒

Additional state that the controller maintains for select collection types.

StatusHistoryRetentionPolicy 🔒

Functions

prepare_initialization

Seed StorageTxn with any state required to instantiate a StorageController.

privatelink_status_history_desc 🔒

read_handle_for_snapshot 🔒

replica_status_history_desc 🔒

sink_status_history_desc 🔒

snapshot_statistics 🔒

Get the current rows in the given statistics table. This is used to bootstrap the statistics tasks.

source_status_history_desc 🔒

swap_updates 🔒

Replace one antichain with another, tracking the overall changes in the returned ChangeBatch.

warm_persist_state_in_background 🔒

Warm up persist state for shard_ids in a background task.