Struct WorkflowDag 

pub struct WorkflowDag {
    pub id: String,
    pub name: String,
    pub nodes: HashMap<String, WorkflowNode>,
    pub edges: Vec<WorkflowEdge>,
}

Directed acyclic graph definition used by collaboration workflows.

Fields

id: String

Stable workflow identifier.

name: String

Human-readable workflow name.

nodes: HashMap<String, WorkflowNode>

Nodes keyed by node identifier.

edges: Vec<WorkflowEdge>

Directed edges describing dependencies.

Implementations

impl WorkflowDag

pub fn new(id: String, name: String) -> WorkflowDag

Creates an empty DAG with the given identifier and name.

pub fn add_node(&mut self, node: WorkflowNode)

Inserts or replaces a node by its identifier.

pub fn add_edge(&mut self, edge: WorkflowEdge)

Appends a directed edge.

pub fn get_entry_nodes(&self) -> Vec<&String>

Returns node identifiers that have no incoming edges.

pub fn get_ready_nodes(&self, completed: &HashSet<String>) -> Vec<String>

Returns nodes whose dependencies have all been completed.

Trait Implementations

impl Clone for WorkflowDag

fn clone(&self) -> WorkflowDag

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkflowDag

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for WorkflowDag

fn deserialize<__D>( __deserializer: __D, ) -> Result<WorkflowDag, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for WorkflowDag

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

where __S: Serializer,

Serialize this value into the given Serde serializer.