Struct LeaderCtl 

pub struct LeaderCtl { /* private fields */ }

The leader’s live control connections to the joined workers (worker id → its stream), kept past the handshake so the leader can drive epochs, commits and shutdown across processes. The leader is itself a worker (D9); it coordinates its own slice in-process and the joined workers here.

Implementations

impl LeaderCtl

pub async fn broadcast(&mut self, msg: ToWorker) -> Result<()>

Send one control message to every joined worker.

pub async fn collect(&mut self) -> Result<Vec<(WorkerId, ToLeader)>>

Wait for the next report from every joined worker (in id order), returning them paired with the worker that sent each. Reads one message per worker.