Struct steno::DagBuilder

pub struct DagBuilder { /* private fields */ }

Used to build a Dag that can then be executed as either a saga or subsaga

Use DagBuilder::append() and DagBuilder::append_parallel() to add nodes to the graph. Use DagBuilder::build() to finish construction and build a Dag.

Implementations

impl DagBuilder

pub fn new(saga_name: SagaName) -> DagBuilder

Begin building a DAG for a saga or subsaga

pub fn append(&mut self, user_node: Node)

Adds a new node to the graph to be run after the most-recently-appended node(s)

The new node will depend on completion of all actions that were added in the last call to append or append_parallel. The idea is to append a sequence of steps that run one after another.

pub fn append_parallel(&mut self, user_nodes: Vec<Node>)

Adds a set of nodes to the graph that depend on the most-recently-appended node(s) but that can be executed concurrently with each other

The new nodes will individually depend on completion of all actions that were added in the last call to append() or append_parallel().

pub fn build(self) -> Result<Dag, DagBuilderError>

Return the constructed DAG

Trait Implementations

impl Debug for DagBuilder

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

Formats the value using the given formatter.