Struct WorkflowDef 

pub struct WorkflowDef { /* private fields */ }

Workflow definition (static DAG structure)

Corresponds to Lean: structure WorkflowDef

Precomputes adjacency lists and a node-to-index map for O(1) lookups.

Implementations

impl WorkflowDef

pub fn new(nodes: Vec<u64>, edges: Vec<Edge>) -> Self

Create a new workflow definition (unchecked).

Prefer validated() for production use to ensure all edge endpoints reference existing nodes.

pub fn validated( nodes: Vec<u64>, edges: Vec<Edge>, ) -> Result<Self, WorkflowError>

Create a validated workflow definition.

Sorts and deduplicates node IDs, then verifies that all edge endpoints reference existing nodes.

Errors

Returns WorkflowError::NodeNotFound if an edge references a node not in the node list.

pub fn node_index(&self, node_id: u64) -> Option<usize>

Look up the dense index for a node ID via binary search.

pub fn require_node(&self, node_id: u64) -> Result<usize, WorkflowError>

Require a node to exist, returning its index or an error.

pub fn is_source(&self, n: u64) -> bool

Check if node has no incoming edges (ready to start)

Corresponds to Lean: def WorkflowDef.is_source

pub fn is_sink(&self, n: u64) -> bool

Check if node has no outgoing edges (terminal)

Corresponds to Lean: def WorkflowDef.is_sink

pub fn dependencies(&self, n: u64) -> Vec<u64>

Get dependencies of a node (predecessors)

Corresponds to Lean: def WorkflowDef.dependencies

pub fn dependents(&self, n: u64) -> Vec<u64>

Get dependents of a node (successors)

Corresponds to Lean: def WorkflowDef.dependents

pub fn node_count(&self) -> usize

Get the number of nodes

pub fn edge_count(&self) -> usize

Get the number of edges

pub fn contains_node(&self, n: u64) -> bool

Check if a node exists in the workflow

pub fn nodes(&self) -> &[u64]

Get all nodes

pub fn edges(&self) -> &[Edge]

Get all edges

Trait Implementations

impl Clone for WorkflowDef

fn clone(&self) -> WorkflowDef

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for WorkflowDef

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

Formats the value using the given formatter.

impl Default for WorkflowDef

fn default() -> WorkflowDef

Returns the “default value” for a type.

impl PartialEq for WorkflowDef

fn eq(&self, other: &WorkflowDef) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for WorkflowDef

impl StructuralPartialEq for WorkflowDef