Struct WorkflowBuilder 

pub struct WorkflowBuilder { /* private fields */ }

Builder for constructing a Workflow.

Each method appends a node and returns self for chaining. Modifiers like after() and when() apply to the most recently added node.

Implementations

impl WorkflowBuilder

pub fn new() -> Self

Start building a workflow.

pub fn agent(self, id: &str, agent: Arc<dyn TextAgent>) -> Self

Add an agent node. The agent’s returned string is stored as a JSON string value.

pub fn function<F, Fut>(self, id: &str, f: F) -> Self

where F: Fn(State) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<Value, String>> + Send + 'static,

Add a function node. The function receives a State clone and returns a JSON value.

pub fn approval(self, id: &str) -> Self

Add an approval node. This node suspends until the controller approves or rejects.

pub fn after(self, deps: &[&str]) -> Self

Set dependencies for the most recently added node. Node runs after all deps are terminal.

pub fn when<G>(self, guard: G) -> Self

where G: Fn(&State) -> bool + Send + Sync + 'static,

Set a guard for the most recently added node. If guard returns false, node is skipped.

pub fn join_any(self) -> Self

For the most recently added node, use join_any semantics: ready when ANY dep finishes (instead of ALL). Skipped only if ALL deps skipped.

pub fn build(self) -> Result<Workflow, WorkflowError>

Build and validate the workflow. Returns an error if there are cycles, unknown dependencies, or duplicate IDs.

Trait Implementations

impl Default for WorkflowBuilder

fn default() -> Self

Returns the “default value” for a type.