risingwave_meta::barrier

Module schedule

Source

Structs§

BarrierScheduler
The sender side of the barrier scheduling queue. Can be cloned and held by other managers to schedule and run barriers.
DatabaseBarrierState
State specific to each database for barrier generation.
DatabaseQueue 🔒
Inner 🔒
A queue for scheduling barriers.
NewBarrier 🔒
PeriodicBarriers
Held by the crate::barrier::worker::GlobalBarrierWorker to execute these commands.
ScheduledBarriers
The receiver side of the barrier scheduling queue.
ScheduledQueueItem 🔒
StatusQueue 🔒

Enums§

MarkReadyOptions 🔒
QueueStatus 🔒

Functions§

tracing_span 🔒

Type Aliases§

DatabaseScheduledQueue 🔒
ScheduledQueue 🔒