risingwave_meta::barrier

Module worker

Source

Modules§

retry_strategy 🔒

Structs§

GlobalBarrierWorker 🔒
crate::barrier::worker::GlobalBarrierWorker sends barriers to all registered compute nodes and collect them, with monotonic increasing epoch numbers. On compute nodes, LocalBarrierManager in risingwave_stream crate will serve these requests and dispatch them to source actors.