Struct mz_compute_client::controller::Instance

struct Instance<T> {
    replicas: ActiveReplication<T>,
    collections: BTreeMap<GlobalId, CollectionState<T>>,
    arranged_logs: BTreeMap<LogVariant, GlobalId>,
    peeks: BTreeMap<Uuid, (GlobalId, T)>,
}

The state we keep for a compute instance.

Fields

replicas: ActiveReplication<T>

The replicas of this compute instance.

collections: BTreeMap<GlobalId, CollectionState<T>>

Tracks expressed since and received upper frontiers for indexes and sinks.

arranged_logs: BTreeMap<LogVariant, GlobalId>

IDs of arranged log sources maintained by this compute instance.

peeks: BTreeMap<Uuid, (GlobalId, T)>

Currently outstanding peeks: identifiers and timestamps.

Implementations

impl<T> Instance<T>

fn collection(&self, id: GlobalId) -> Result<&CollectionState<T>, ComputeError>

Acquire a handle to the collection state associated with id.

fn collection_mut(
    &mut self,
    id: GlobalId
) -> Result<&mut CollectionState<T>, ComputeError>

Acquire a mutable handle to the collection state associated with id.

fn activate<'a>(
    &'a mut self,
    storage_controller: &'a mut dyn StorageController<Timestamp = T>
) -> ActiveInstance<'a, T>

Acquire an ActiveInstance by providing a storage controller.

impl<T> Instance<T>where
    T: Timestamp + Lattice,
    ComputeGrpcClient: ComputeClient<T>,

fn new(
    build_info: &'static BuildInfo,
    arranged_logs: BTreeMap<LogVariant, GlobalId>,
    max_result_size: u32
) -> Self

fn initialization_complete(&mut self)

Marks the end of any initialization commands.

Intended to be called by Controller, rather than by other code (to avoid repeated calls).

fn drop(self)

Drop this compute instance.

Panics

• If the compute instance still has active replicas.

Trait Implementations

impl<T: Debug> Debug for Instance<T>

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

Formats the value using the given formatter.