Skip to main content

initialize_networking

Function initialize_networking 

Source
pub async fn initialize_networking(
    workers: usize,
    process: usize,
    addresses: Vec<String>,
    refill: BytesRefill,
    enable_zero_copy_binary: bool,
) -> Result<(Vec<AllocatorBuilder>, Box<dyn Any + Send>), Error>
Expand description

Creates communication mesh from cluster config.

enable_zero_copy_binary selects between the zero-copy serialized (ProcessBuilder::new_bytes_vector) and regular mpsc-based (ProcessBuilder::new_typed_vector) intra-process allocator flavors.