Expand description
Worker-local state for compute timely instances.
Structs§
- Active
Compute 🔒State - A wrapper around ComputeState with a live timely worker and response channel.
- Collection
State - State maintained for a compute collection.
- Compute
State - Worker-local state that is maintained across dataflows.
- Dropped
Collection - State remembered about a dropped compute collection.
- Hydration
Event - An event reporting the hydration status of an LIR node in a dataflow.
- Index
Peek - An in-progress index-backed peek, and data to eventually fulfill it.
- Persist
Peek - An in-progress Persist peek.
- Reported
Frontiers 🔒 - The frontiers we have reported to the controller for a collection.
- Sink
Token - A token that keeps a sink alive.
Enums§
- Pending
Peek - A peek against either an index or a Persist collection.
- Reported
Frontier - A frontier we have reported to the controller, or the least frontier we are allowed to report.