Struct EnvVar 

pub struct EnvVar { /* private fields */ }

Environment variable.

When multiple nodes are running, they may need to share the same data or read the same configuration information. Environment variables can meet this requirement. Before all nodes run, the user builds a EnvVar and sets all the environment variables. One EnvVar corresponds to one dag. All nodes in a job can be shared and immutable at runtime. environment variables.

Variables that EnvVar should have:

• NodeTable : a mapping from node’s name to NodeId. During the runtime of a Graph, NodeTable allows each Node to look up the id of a specific node by its name.

Implementations

impl EnvVar

pub fn get_node_id(&self, node_name: &str) -> Option<&NodeId>

Get a Node’s NodeId by providing its name.

impl EnvVar

pub fn new(node_table: NodeTable) -> EnvVar

Allocate a new EnvVar.

pub fn set<H>(&mut self, name: &str, var: H)

where H: Send + Sync + 'static,

Set a global variables.

Example

use dagrs::{EnvVar, NodeTable};

env.set("Hello", "World".to_string());

pub fn get<H>(&self, name: &str) -> Option<H>

where H: Send + Sync + Clone + 'static,

Get environment variables through keys of type &str.

Note: This method will clone the value. To avoid cloning, use get_ref.

pub fn get_ref<H>(&self, name: &str) -> Option<&H>

where H: Send + Sync + 'static,

Get environment variables through keys of type &str.

Trait Implementations

impl Clone for EnvVar

fn clone(&self) -> EnvVar

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EnvVar

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.