risingwave_stream::task::barrier_manager

Module managed_state

Source

Structs§

BarrierState 🔒
DatabaseManagedBarrierState 🔒
InflightActorState 🔒
IssuedState 🔒
ManagedBarrierState 🔒
ManagedBarrierStateDebugInfo 🔒
PartialGraphManagedBarrierState 🔒
ResetDatabaseOutput 🔒
ResettingDatabaseState 🔒
SuspendedDatabaseState 🔒

Enums§

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