Struct erdos::Configuration

pub struct Configuration {
    pub index: NodeId,
    pub num_threads: usize,
    pub data_addresses: Vec<SocketAddr>,
    pub control_addresses: Vec<SocketAddr>,
    pub graph_filename: Option<String>,
    pub logging_level: Option<Level>,
}

Stores the configuration parameters of a node.

Fields

index: NodeId

The index of the node.

num_threads: usize

The number of OS threads the node will use.

data_addresses: Vec<SocketAddr>

Mapping between node indices and data socket addresses.

control_addresses: Vec<SocketAddr>

Mapping between node indices and control socket addresses.

graph_filename: Option<String>

DOT file to export dataflow graph.

logging_level: Option<Level>

The logging level of the logger initialized by ERDOS. If None, ERDOS will not initialize a logger. Defaults to Level::DEBUG when compiling in debug mode, Level::INFO when compiling in release mode.

While tracing provides extensions for connecting additional subscribers, note that these may impact performance.

Implementations

impl Configuration

pub fn new(
    node_index: NodeId,
    data_addresses: Vec<SocketAddr>,
    control_addresses: Vec<SocketAddr>,
    num_threads: usize
) -> Self

Creates a new node configuration.

pub fn from_args(args: &ArgMatches<'_>) -> Self

Creates a node configuration from command line arguments.

pub fn export_dataflow_graph(self, filename: &str) -> Self

Upon executing, exports the dataflow graph as a DOT file.

pub fn with_logging_level(self, level: Level) -> Self

Sets the logging level.

pub fn disable_logger(self) -> Self

ERDOS will not initialize a logger if this method is called.

Trait Implementations

impl Clone for Configuration

fn clone(&self) -> Configuration

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.