Struct DefaultNode 

pub struct DefaultNode { /* private fields */ }

Default node type

DefaultNode is a default implementation of the Node trait. Users can use this node type to build tasks to meet most needs.

Create a DefaultNode:

• use the method new. Required attributes: node’s name; NodeTable(for id allocation).

use dagrs::{NodeName, NodeTable, DefaultNode};

let node_name = "Node X";
let mut node_table = NodeTable::new();
let mut node = DefaultNode::new(
    NodeName::from(node_name),
    &mut node_table,
);

• use the method with_action. Required attributes: node’s name; NodeTable(for id allocation); execution logic Action.

use dagrs::{NodeName, NodeTable, DefaultNode, EmptyAction};

let node_name = "Node X";
let mut node_table = NodeTable::new();
let mut node = DefaultNode::with_action(
    NodeName::from(node_name),
    EmptyAction,
    &mut node_table,
);

Implementations

impl DefaultNode

pub fn new(name: String, node_table: &mut NodeTable) -> DefaultNode

pub fn with_action( name: String, action: impl Action + 'static, node_table: &mut NodeTable, ) -> DefaultNode

pub fn set_action(&mut self, action: impl Action + 'static)

Trait Implementations

impl Node for DefaultNode

fn id(&self) -> NodeId

id is the unique identifier of each node, it will be assigned by the NodeTable when creating a new node, you can find this node through this identifier.

fn name(&self) -> String

The node’s name.

fn input_channels(&mut self) -> &mut InChannels

Input Channels of this node.

fn output_channels(&mut self) -> &mut OutChannels

Output Channels of this node.

fn run<'life0, 'async_trait>( &'life0 mut self, env: Arc<EnvVar>, ) -> Pin<Box<dyn Future<Output = Output> + Send + 'async_trait>>

where 'life0: 'async_trait, DefaultNode: 'async_trait,

Execute a run of this node.

fn is_condition(&self) -> bool

Return true if this node is conditional node. By default, it returns false.

fn loop_structure(&self) -> Option<Vec<Arc<Mutex<dyn Node>>>>

Returns the list of nodes that are part of this node’s loop structure, if any.