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.
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 🔒