Struct ModuleDagDefinition 

pub struct ModuleDagDefinition {
    pub nodes: Vec<ModuleDagNodeDef>,
    pub edges: Vec<ModuleDagEdgeDef>,
    pub entry_nodes: Vec<String>,
    pub default_policy: Option<DagNodeExecutionPolicy>,
    pub metadata: HashMap<String, String>,
}

Fields

nodes: Vec<ModuleDagNodeDef>

edges: Vec<ModuleDagEdgeDef>

entry_nodes: Vec<String>

default_policy: Option<DagNodeExecutionPolicy>

metadata: HashMap<String, String>

Implementations

impl ModuleDagDefinition

pub fn builder() -> ModuleDagBuilder

Returns a fluent builder.

let dag = ModuleDagDefinition::builder()
    .edge(&login_node, &cate_list_node)
    .edge(&cate_list_node, &brand_rank_downloader)
    .edge(&cate_list_node, &goods_cate_downloader)
    .edge(&brand_rank_downloader, &download_url_node)
    .edge(&goods_cate_downloader, &download_url_node)
    .edge(&download_url_node, &download_file_node)
    .build();

Nodes are collected automatically from edges in first-seen order. Entry nodes (those with no incoming edges) are derived automatically. Isolated nodes (no edges at all) can be added with .node().

pub fn from_linear_steps(steps: Vec<Arc<dyn ModuleNodeTrait>>) -> Self

Trait Implementations

impl Clone for ModuleDagDefinition

fn clone(&self) -> ModuleDagDefinition

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for ModuleDagDefinition

fn default() -> ModuleDagDefinition

Returns the “default value” for a type.