Enum timely::Configuration

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

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) + 'static + Sync + Send>

Closure to create a new logger for a communication thread

Methods

impl Configuration

pub fn from_args<I>(args: I) -> Result<Configuration, String> where
    I: Iterator<Item = 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 + 'static>), String>

Attempts to assemble the described communication infrastructure.