Module mz_storage_client::controller::collection_mgmt

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

Structs

• CollectionManager
• MonotonicAppender
  A “oneshot”-like channel that allows you to append a set of updates to a pre-defined GlobalId.

Constants

• CHANNEL_CAPACITY 🔒
• DEFAULT_TICK 🔒

Functions

• notify_listeners 🔒
• write_task 🔒
  Spawns an mz_ore::task that will continuously bump the upper for the specified collection, and append data that is sent via the provided mpsc::Sender.

Type Definitions

• ShutdownSender 🔒
• WriteChannel 🔒
• WriteTask 🔒