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
• PendingCompactionCommand 🔒
• 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 🔒
• snapshot_statistics 🔒
  Get the current rows in the given statistics table. This is used to bootstrap the statistics tasks.
• source_status_history_desc 🔒
• warm_persist_state_in_background 🔒
  Warm up persist state for shard_ids in a background task.