Struct mz_storage::controller::StorageControllerState

pub struct StorageControllerState<T: Timestamp + Lattice + Codec64 + TimestampManipulation, S = Memory<Postgres>> {
    pub(crate) collections: BTreeMap<GlobalId, CollectionState<T>>,
    pub(crate) exports: BTreeMap<GlobalId, ExportState<T>>,
    pub(crate) exported_collections: BTreeMap<GlobalId, Vec<GlobalId>>,
    pub(crate) stash: S,
    pub(crate) persist_write_handles: PersistWorker<T>,
    persist_read_handles: PersistWorker<T>,
    stashed_response: Option<StorageResponse<T>>,
    pub(crate) collection_manager: CollectionManager,
    pub(crate) introspection_ids: HashMap<IntrospectionType, GlobalId>,
}

Controller state maintained for each storage instance.

Fields

collections: BTreeMap<GlobalId, CollectionState<T>>

Collections maintained by the storage controller.

This collection only grows, although individual collections may be rendered unusable. This is to prevent the re-binding of identifiers to other descriptions.

exports: BTreeMap<GlobalId, ExportState<T>>

exported_collections: BTreeMap<GlobalId, Vec<GlobalId>>

stash: S

persist_write_handles: PersistWorker<T>

Write handle for persist shards.

persist_read_handles: PersistWorker<T>

Read handles for persist shards.

These handles are on the other end of a Tokio task, so that work can be done asynchronously without blocking the storage controller.

stashed_response: Option<StorageResponse<T>>

collection_manager: CollectionManager

Interface for managed collections

introspection_ids: HashMap<IntrospectionType, GlobalId>

Tracks which collection is responsible for which IntrospectionType.

Implementations

impl<T: Timestamp + Lattice + Codec64 + From<EpochMillis> + TimestampManipulation> StorageControllerState<T>

pub(crate) async fn new(
    postgres_url: String,
    tx: UnboundedSender<StorageResponse<T>>,
    now: NowFn
) -> Self

Trait Implementations

impl<T: Debug + Timestamp + Lattice + Codec64 + TimestampManipulation, S: Debug> Debug for StorageControllerState<T, S>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.