Crate pureflow_engine 

High-level workflow orchestration for Pureflow.

Structs

BatchNodeExecutor

Node executor adapter for host-owned batch implementations such as WASM.

DeadlockWatchdogPolicy

Configuration for no-progress deadlock detection.

FeedbackLoopRunPolicy

Startup and termination behavior for feedback-loop workflows.

SingleNodeExecutorRegistry

Registry adapter that runs every workflow node through the same executor.

StaticNodeExecutorRegistry

In-memory registry keyed by workflow node identifier.

WorkflowDeadlockDiagnostic

Diagnostic state reported when the workflow watchdog detects no progress.

WorkflowOutputContracts

Output-port contract subset used by the workflow runner.

WorkflowRunPolicy

Runtime policy for executing one workflow graph.

WorkflowRunSummary

Aggregate outcome for one workflow run.

Enums

CycleRunPolicy

Runtime behavior for cyclic workflow graphs.

FeedbackLoopStartup

How a feedback-loop graph is started.

FeedbackLoopTermination

How a feedback-loop graph reaches a terminal state.

WorkflowTerminalState

Terminal state for one workflow run.

WorkflowWatchdogPolicy

Runtime watchdog behavior for workflow execution.

Traits

NodeExecutorRegistry

Registry that resolves workflow nodes to runtime executors.

Functions

run_workflow

Execute the workflow by invoking the provided executor for each node.

run_workflow_summary

Execute the workflow through one executor and return an aggregate summary.

run_workflow_with_contracts

Execute the workflow through one executor with output contract validation.

run_workflow_with_contracts_summary

Execute the workflow through one executor with output contract validation.

run_workflow_with_metadata_sink

Execute the workflow with one executor and emit metadata records through a sink.

run_workflow_with_metadata_sink_summary

Execute the workflow with one executor, emit metadata, and return a summary.

run_workflow_with_observers

Execute the workflow through one executor and report observer records.

run_workflow_with_observers_summary

Execute the workflow through one executor and report observer records.

run_workflow_with_policy

Execute the workflow through one executor with an explicit run policy.

run_workflow_with_policy_summary

Execute the workflow through one executor with an explicit run policy.

run_workflow_with_registry

Execute the workflow by resolving one executor for each node from a registry.

run_workflow_with_registry_and_metadata_sink

Execute the workflow through a registry and emit metadata records.

run_workflow_with_registry_and_metadata_sink_summary

Execute the workflow through a registry and emit metadata records.

run_workflow_with_registry_and_observers

Execute the workflow through a registry and report observer records.

run_workflow_with_registry_and_observers_summary

Execute the workflow through a registry and report observer records.

run_workflow_with_registry_contracts

Execute the workflow through a registry with output contract validation.

run_workflow_with_registry_contracts_and_observers

Execute the workflow through a registry with output contract validation.

run_workflow_with_registry_contracts_and_observers_summary

Execute the workflow through a registry with output contract validation.

run_workflow_with_registry_contracts_summary

Execute the workflow through a registry with output contract validation.

run_workflow_with_registry_policy

Execute the workflow through a registry with an explicit run policy.

run_workflow_with_registry_policy_and_metadata_sink

Execute the workflow through a registry with an explicit run policy and emit metadata records.

run_workflow_with_registry_policy_and_metadata_sink_summary

Execute the workflow through a registry with an explicit run policy and emit metadata records.

run_workflow_with_registry_policy_summary

Execute the workflow through a registry with an explicit run policy.

run_workflow_with_registry_summary

Execute the workflow by resolving one executor for each node from a registry.