mz_cluster::communication

Function initialize_networking

Source 
pub async fn initialize_networking<P>(
    workers: usize,
    process: usize,
    addresses: Vec<String>,
    epoch: ClusterStartupEpoch,
    refill: BytesRefill,
    builder_fn: impl Fn(TcpBuilder<P::Peer>) -> GenericBuilder,
) -> Result<(Vec<GenericBuilder>, Box<dyn Any + Send>), Error>
where
    P: PeerBuilder,
Expand description

Creates communication mesh from cluster config