Crate mz_storage_controller

Source
Expand description

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.