Module mz_compute::compute_state

Worker-local state for compute timely instances.

Structs

• ActiveComputeState 🔒
  A wrapper around ComputeState with a live timely worker and response channel.
• CollectionState
  State maintained for a compute collection.
• ComputeState
  Worker-local state that is maintained across dataflows.
• DroppedCollection
  State remembered about a dropped compute collection.
• HydrationEvent
  An event reporting the hydration status of an LIR node in a dataflow.
• IndexPeek
  An in-progress index-backed peek, and data to eventually fulfill it.
• PersistPeek
  An in-progress Persist peek.
• ReportedFrontiers 🔒
  The frontiers we have reported to the controller for a collection.
• SinkToken
  A token that keeps a sink alive.

Enums

• PendingPeek
  A peek against either an index or a Persist collection.
• ReportedFrontier
  A frontier we have reported to the controller, or the least frontier we are allowed to report.