Module worker

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.