Struct mz_compute_client::controller::InstanceState

struct InstanceState<T: ComputeControllerTimestamp> {
    client: Client<T>,
    replicas: BTreeSet<ReplicaId>,
    collections: BTreeMap<GlobalId, Collection<T>>,
    read_holds_tx: UnboundedSender<(GlobalId, ChangeBatch<T>)>,
}

Fields

client: Client<T>

replicas: BTreeSet<ReplicaId>

collections: BTreeMap<GlobalId, Collection<T>>

read_holds_tx: UnboundedSender<(GlobalId, ChangeBatch<T>)>

Sender for updates to collection read holds.

Copies of this sender are given to ReadHolds that are created in InstanceState::acquire_read_hold.

Implementations

impl<T: ComputeControllerTimestamp> InstanceState<T>

fn new( client: Client<T>, collections: BTreeMap<GlobalId, Collection<T>>, read_holds_tx: UnboundedSender<(GlobalId, ChangeBatch<T>)>, ) -> Self

fn collection(&self, id: GlobalId) -> Result<&Collection<T>, CollectionMissing>

pub fn call<F>(&self, f: F)

where F: FnOnce(&mut Instance<T>) + Send + 'static,

pub async fn call_sync<F, R>(&self, f: F) -> R

where F: FnOnce(&mut Instance<T>) -> R + Send + 'static, R: Send + 'static,

pub fn acquire_read_hold( &self, id: GlobalId, ) -> Result<ReadHold<T>, CollectionMissing>

Acquires a ReadHold for the identified compute collection.

fn get_time_dependence( &self, id: GlobalId, ) -> Result<Option<TimeDependence>, CollectionMissing>

Return the stored time dependence for a collection.

pub async fn dump(&self) -> Result<Value, Error>

Returns the InstanceState formatted as JSON.

Trait Implementations

impl<T: Debug + ComputeControllerTimestamp> Debug for InstanceState<T>

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

Formats the value using the given formatter.