Struct DagFlow 

pub struct DagFlow<Input = (), Output = ()> { /* private fields */ }

Directed Acyclic Graph (DAG) workflow builder

Implementations

impl DagFlow

pub fn new() -> Self

Create a new DAG workflow builder

pub fn add_node<S, Input>( &self, name: &str, service: S, ) -> NodeBuilder<'_, Input, S::Response>

where S: Service<Task<Input, (), ()>> + Send + 'static, S::Future: Send + 'static,

Add a node to the DAG

pub fn node<F, Input, O, FnArgs>(&self, node: F) -> NodeBuilder<'_, Input, O>

where TaskFn<F, Input, (), FnArgs>: Service<Task<Input, (), ()>, Response = O>, F: Send + 'static, Input: Send + 'static, FnArgs: Send + 'static, <TaskFn<F, Input, (), FnArgs> as Service<Task<Input, (), ()>>>::Future: Send + 'static,

Add a task function node to the DAG

pub fn route<F, Input, O, FnArgs>(&self, router: F) -> NodeBuilder<'_, Input, O>

where TaskFn<F, Input, (), FnArgs>: Service<Task<Input, (), ()>, Response = O>, F: Send + 'static, Input: Send + 'static, FnArgs: Send + 'static, <TaskFn<F, Input, (), FnArgs> as Service<Task<Input, (), ()>>>::Future: Send + 'static, O: Into<NodeIndex>,

Add a routing node to the DAG

pub fn build(self) -> Result<DagExecutor, String>

Build the DAG executor

Trait Implementations

impl<Input: Debug, Output: Debug> Debug for DagFlow<Input, Output>

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

Formats the value using the given formatter.

impl Default for DagFlow

fn default() -> Self

Returns the “default value” for a type.