Enum timely_communication::initialize::Configuration

pub enum Configuration {
    Thread,
    Process(usize),
    Cluster {
        threads: usize,
        process: usize,
        addresses: Vec<String>,
        report: bool,
        log_fn: Box<dyn Fn(CommunicationSetup) -> Option<Logger<CommunicationEvent, CommunicationSetup>> + Send + Sync>,
    },
}

Possible configurations for the communication infrastructure.

Variants

Thread

Use one thread.

Process(usize)

Use one process with an indicated number of threads.

Cluster

Expect multiple processes.

Fields of Cluster

threads: usize

Number of per-process worker threads

process: usize

Identity of this process

addresses: Vec<String>

Addresses of all processes

report: bool

Verbosely report connection process

log_fn: Box<dyn Fn(CommunicationSetup) -> Option<Logger<CommunicationEvent, CommunicationSetup>> + Send + Sync>

Closure to create a new logger for a communication thread

Methods

impl Configuration

pub fn options() -> Options

Returns a getopts::Options struct that can be used to print usage information in higher-level systems.

pub fn from_args<I: Iterator<Item = String>>(
    args: I
) -> Result<Configuration, String>

Constructs a new configuration by parsing supplied text arguments.

Most commonly, this uses std::env::Args() as the supplied iterator.

pub fn try_build(self) -> Result<(Vec<GenericBuilder>, Box<dyn Any>), String>

Attempts to assemble the described communication infrastructure.