Module instance

A controller for a compute instance.

Structs

ActiveSubscribe 🔒

Client 🔒

A client for an Instance task.

CollectionIntrospection 🔒

Manages certain introspection relations associated with a collection. Upon creation, it adds rows to introspection relations. When dropped, it retracts its managed rows.

CollectionState 🔒

State maintained about individual compute collections.

FrontiersIntrospectionState 🔒

Instance 🔒

The state we keep for a compute instance.

PendingPeek 🔒

A note of an outstanding peek response.

RefreshIntrospectionState 🔒

Information needed to compute introspection updates for a REFRESH materialized view when the write frontier advances.

ReplicaCollectionIntrospection 🔒

Maintains the introspection state for a given replica and collection, and ensures that reported introspection data is retracted when the collection is dropped.

ReplicaCollectionState 🔒

ReplicaExists 🔒

ReplicaMissing 🔒

ReplicaState 🔒

State maintained about individual replicas.

SharedCollectionState 🔒

Collection state shared with the ComputeController.

Enums

DataflowCreationError 🔒

PeekError 🔒

ReadPolicyError 🔒

Type Aliases

Command

A command sent to an Instance task.

ReplicaResponse 🔒

A response from a replica, composed of a replica ID, the replica’s current epoch, and the compute response itself.