Function mz_cluster::communication::initialize_networking

source ยท 
pub async fn initialize_networking(
    workers: usize,
    process: usize,
    addresses: Vec<String>,
    epoch: ClusterStartupEpoch,
) -> Result<(Vec<GenericBuilder>, Box<dyn Any + Send>), Error>
Expand description

Creates communication mesh from cluster config