Struct EnhancedFlowOrchestrator 

pub struct EnhancedFlowOrchestrator { /* private fields */ }

增强的流程编排器

Implementations

impl EnhancedFlowOrchestrator

pub fn new() -> Self

创建新的编排器

pub fn with_config(config: OrchestratorConfig) -> Self

使用配置创建编排器

pub fn create_execution_plan( &self, nodes: Vec<ExecutionNode>, env_vars: HashMap<String, Value>, flow_vars: HashMap<String, Value>, workflow_name: String, workflow_version: String, ) -> Result<ExecutionPlan>

从节点列表创建执行计划

pub fn analyze_complexity(&self, plan: &ExecutionPlan) -> ExecutionComplexity

分析执行计划的复杂度

Trait Implementations

impl Default for EnhancedFlowOrchestrator

fn default() -> Self

Returns the “default value” for a type.

impl FlowPlanner for EnhancedFlowOrchestrator

type Input = (Vec<ExecutionNode>, HashMap<String, Value>, HashMap<String, Value>, String, String)

type Output = ExecutionPlan

type Error = Error

fn create_execution_plan( &self, input: Self::Input, ) -> Result<Self::Output, Self::Error>

创建执行计划

fn optimize_plan(&self, plan: Self::Output) -> Result<Self::Output, Self::Error>

优化执行计划