Struct NodeNetwork

pub struct NodeNetwork {
    pub node_network: HashMap<String, Vec<NodeNetworkItem>>,
}

NodeNetwork

The NodeNetwork type represents the network of nodes. It is just a HashMap that is keyed my a string that represents a grouping of nodes. This grouping is not required by will allow for having various groups of downstream nodes receive different messages from another group. While this grouping is optional, it does provide for increased flexibility.

The way that this would work is that a node’s implementation of the FBPNodeTrait::process_message would need to determine if there were a separate grouping of nodes for a specific need and only send specific messages to that group. A made up example might be that a separate logging group exists and the node would performs its ‘normal’ processing and then send that result on to the ‘normal’ outputs, while it could also send logging information to a logging group.

The value of the HashMap is a Vector of NodeNetworkItems that represent an FBP Node that will be constructed and placed into the same position as the NodeNetworkItem in the NodeNetwork.

Fields

node_network: HashMap<String, Vec<NodeNetworkItem>>

Implementations

impl NodeNetwork

pub fn new() -> Self

pub fn node_network(&self) -> &HashMap<String, Vec<NodeNetworkItem>>

pub fn find_node_by_name( &mut self, node_name: String, key: Option<String>, ) -> Option<&mut NodeNetworkItem>

pub fn add_node(&mut self, node_name: String, key: Option<String>)

pub fn add_exiting_node(&mut self, a_node: NodeNetworkItem, key: Option<String>)

Trait Implementations

impl Clone for NodeNetwork

fn clone(&self) -> NodeNetwork

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NodeNetwork

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for NodeNetwork

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for NodeNetwork

fn eq(&self, other: &NodeNetwork) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for NodeNetwork

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for NodeNetwork

impl StructuralPartialEq for NodeNetwork