Struct GraphFlow 

pub struct GraphFlow<B>
where
    B: WireFormatBackend,
{ /* private fields */ }

Directed Acyclic Graph (Graph) workflow builder

Implementations

impl<B> GraphFlow<B>

where B: Backend + WireFormatBackend,

pub fn new(name: &str) -> Self

Create a new Graph workflow builder

pub fn new_typed(name: &str) -> Self

Create a new Graph workflow builder with typed inputs and output

pub fn to_dot(&self) -> String

Export the Graph to DOT format

impl<B> GraphFlow<B>

where B: Backend + WireFormatBackend,

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

where S: Service<Task<Input>> + Send + 'static + Sync + Clone, S::Future: Send + 'static, B::Codec: Codec<Input, Compact = B::Compact, Error = CodecError> + Codec<S::Response, Compact = B::Compact, Error = CodecError> + Send + Sync + Clone + 'static, CodecError: Into<BoxDynError> + Send + 'static, S::Error: Into<BoxDynError>, B: BackendConfig + Send + Sync + 'static, Input: GraphCodec<B, Error = CodecError> + Send + Sync + 'static + DeserializeOwned, S::Response: Serialize,

Add a named node to the Graph

pub fn add_task<F, Input, O, FnArgs, Err, CodecError>( &self, task: F, ) -> NodeBuilder<'_, Input, O, B>

where TaskFn<F, Input, FnArgs>: Service<Task<Input>, Response = O, Error = Err> + Clone, F: Send + 'static + Sync, Input: Send + 'static + Sync + GraphCodec<B, Error = CodecError> + DeserializeOwned, FnArgs: Send + 'static + Sync, <TaskFn<F, Input, FnArgs> as Service<Task<Input>>>::Future: Send + 'static, B::Codec: Codec<Input, Compact = B::Compact, Error = CodecError> + 'static + Codec<O, Compact = B::Compact, Error = CodecError> + Send + Sync + Clone, CodecError: Into<BoxDynError> + Send + 'static, Err: Into<BoxDynError>, B: BackendConfig + Send + Sync + 'static, O: Serialize,

Add a task function node to the Graph

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

where TaskFn<F, Input, FnArgs>: Service<Task<Input>, Response = O, Error = Err> + Clone, F: Send + 'static + Sync, Input: Send + 'static + Sync + GraphCodec<B, Error = CodecError> + DeserializeOwned, FnArgs: Send + 'static + Sync, <TaskFn<F, Input, FnArgs> as Service<Task<Input>>>::Future: Send + 'static, O: Into<NodeIndex> + Serialize, B::Codec: Codec<Input, Compact = B::Compact, Error = CodecError> + 'static + Codec<O, Compact = B::Compact, Error = CodecError> + Send + Sync + Clone, CodecError: Into<BoxDynError> + Send + 'static, Err: Into<BoxDynError>, B: BackendConfig + Send + Sync + 'static,

Add a routing node to the Graph

pub fn validate(&self) -> Result<(), GraphFlowError>

Validate the Graph for cycles

Trait Implementations

impl<B> Debug for GraphFlow<B>

where B: WireFormatBackend + Debug, B::Compact: Debug,

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

Formats the value using the given formatter.

impl<B> Display for GraphFlow<B>

where B: Backend + WireFormatBackend,

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

Formats the value using the given formatter.

impl<B, Compact, Err> IntoWorkerService<B, RootGraphService<B>> for GraphFlow<B>

where B: Backend<Error = Err, Task = Task<Compact>> + WireFormatBackend<Compact = Compact> + Clone, Err: Error + Send + Sync + 'static, B::Compact: Send + Sync + 'static + Clone, RootGraphService<B>: Service<Task<Compact>>,

type Task = Task<Compact>

The task type processed by the worker.

type Backend = B

The backend type used by the worker service.

fn into_service(self, b: B) -> WorkerService<B, RootGraphService<B>>

Builds a worker service from the provided backend.