Module managed_state

risingwave_stream::task::barrier_worker

Module managed_state 

Source

Structs§

BarrierState 🔒
BarrierToComplete 🔒
InflightActorState 🔒
IssuedState 🔒
ManagedBarrierState 🔒
ManagedBarrierStateDebugInfo 🔒
PartialGraphManagedBarrierState 🔒
Part of PartialGraphState
PartialGraphState 🔒
Per-partial-graph barrier state manager. Handles barriers for one specific partial graph. Part of ManagedBarrierState in super::LocalBarrierWorker.
ResetPartialGraphOutput 🔒
SuspendedPartialGraphState 🔒

Enums§

InflightActorStatus 🔒
ManagedBarrierStateEvent 🔒
ManagedBarrierStateInner 🔒
The state machine of local barrier manager.
PartialGraphStatus 🔒