risingwave_stream::task::barrier_worker

Module managed_state

Source

Structs§

BarrierState 🔒
DatabaseManagedBarrierState 🔒
Per-database barrier state manager. Handles barriers for one specific database. Part of ManagedBarrierState in super::LocalBarrierWorker.
InflightActorState 🔒
IssuedState 🔒
ManagedBarrierState 🔒
ManagedBarrierStateDebugInfo 🔒
PartialGraphManagedBarrierState 🔒
Part of DatabaseManagedBarrierState
ResetDatabaseOutput 🔒
ResettingDatabaseState 🔒
SuspendedDatabaseState 🔒

Enums§

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