Struct DagEngine 

pub struct DagEngine { /* private fields */ }

DAG execution engine — validates and runs workflow graphs.

Implementations

impl DagEngine

pub fn new() -> Self

pub fn register_workflow(&mut self, workflow: Workflow) -> WorkflowResult<()>

Register a workflow definition.

pub fn get_workflow(&self, id: &str) -> WorkflowResult<&Workflow>

Get a workflow by ID.

pub fn remove_workflow(&mut self, id: &str) -> WorkflowResult<Workflow>

Remove a workflow.

pub fn list_workflows(&self) -> Vec<&Workflow>

List all registered workflows.

pub fn validate_dag(&self, workflow: &Workflow) -> WorkflowResult<()>

Validate the DAG — check for cycles and unsatisfied dependencies.

pub fn topological_sort( &self, workflow: &Workflow, ) -> WorkflowResult<Vec<String>>

Topological sort of steps — returns execution order or error if cycle.

pub fn start_execution(&mut self, workflow_id: &str) -> WorkflowResult<String>

Start a new execution of a workflow.

pub fn get_progress( &self, execution_id: &str, ) -> WorkflowResult<ExecutionProgress>

Get execution progress.

pub fn pause_execution(&mut self, execution_id: &str) -> WorkflowResult<()>

Pause a running execution.

pub fn resume_execution(&mut self, execution_id: &str) -> WorkflowResult<()>

Resume a paused execution.

pub fn cancel_execution(&mut self, execution_id: &str) -> WorkflowResult<()>

Cancel a running execution.

pub fn get_execution( &self, execution_id: &str, ) -> WorkflowResult<&ExecutionContext>

Get execution context.

pub fn visualize_mermaid(&self, workflow_id: &str) -> WorkflowResult<String>

Generate a Mermaid diagram for a workflow.

Trait Implementations

impl Default for DagEngine

fn default() -> Self

Returns the “default value” for a type.