Struct WorkflowEngine 

pub struct WorkflowEngine { /* private fields */ }

Workflow execution engine with a pre-built agent map.

Agents are keyed by the names used in WorkflowStepDef variants (e.g. the agent field of Run). The engine looks them up by name at execution time; an unknown agent name fails the step with a clear error rather than panicking.

Implementations

impl WorkflowEngine

pub fn new(agents: HashMap<String, AgentHandle>) -> Self

Create a new engine with the given agent map and fresh SharedMemory / Consensus instances.

pub fn with_memory(self, memory: Arc<SharedMemory>) -> Self

Replace the default SharedMemory with a caller-supplied one (e.g. to share state across multiple workflow runs).

pub fn with_consensus(self, consensus: Arc<Consensus>) -> Self

Replace the default Consensus with a caller-supplied one.

pub fn shared_memory(&self) -> &SharedMemory

Borrow the shared memory (for tests / inspection).

pub fn consensus(&self) -> &Consensus

Borrow the consensus (for tests / inspection).

pub async fn execute(&self, workflow: &WorkflowDefinition) -> WorkflowResult

Execute the workflow top-to-bottom. Stops at the first failing step (subsequent steps are not run).