Module compute_state 

Worker-local state for compute timely instances.

Modules

error_scan 🔒

An index peek’s walk over its error trace, the phase that runs before PeekResultIterator walks the ok trace.

peek_budget 🔒

What a worker activation may spend walking index peeks before it hands the worker back.

peek_metrics 🔒

What an index peek reports about the walk that answers it.

peek_offload 🔒

Driving an index peek’s walk away from the timely worker that owns it.

peek_result_iterator 🔒

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

peek_scan 🔒

An index peek’s walk over the two traces that answer it, as one suspendable object.

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.

IndexPeek

An in-progress index-backed peek, and data to eventually fulfill it.

PeekRowIterationConfig 🔒

Cheap handles on the dyncfgs that bound how many rows a peek may examine.

PeekRowIterationTracker 🔒

Counts the rows a peek has examined on this worker and fails it once that exceeds the limit.

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.

Functions

peek_row_iteration_limit 🔒