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ยง
- Collection
State ๐ - State maintained about individual collections.
- Controller
- A storage controller for a storage instance.
- Ingestion
State ๐ - State maintained about ingestions and ingestion exports
- Pending
Oneshot ๐Ingestion - Status
History ๐Desc - A description of a status history collection.
Enumsยง
- Collection
State ๐Extra - Additional state that the controller maintains for select collection types.
- Status
History ๐Retention Policy
Functionsยง
- prepare_
initialization - Seed
StorageTxn
with any state required to instantiate aStorageController
. - 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.