Skip to main content

connect

Function connect 

Source
pub async fn connect(
    cfg: &ClusterCfg,
    base_fp: &str,
) -> Result<(Members, TcpListener, Coord)>
Expand description

Settle this worker’s membership: bind its exchange listener, then lead or join. base_fp is the topology fingerprint without the member clause — the leader broadcasts it and every joiner checks its own against it, so a worker whose steps/vnodes differ is rejected before it runs. Returns the settled Members, the exchange listener (for mesh), and this process’s coordination role (Coord) with its live control connection(s).