Module compute_state

Worker-local state for compute timely instances.

Modules

peek_result_iterator 🔒

Code for extracting a peek result out of compute state/an arrangement.

peek_stash 🔒

For eligible peeks, we send the result back via the peek stash (aka persist blob), instead of inline in ComputeResponse.

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

PeekStatus 🔒

For keeping track of the state of pending or ready peeks, and managing control flow.

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.