Struct DynamicFlowExecutor 

pub struct DynamicFlowExecutor { /* private fields */ }

统一的动态流程执行器

Implementations

impl DynamicFlowExecutor

pub fn new(config: WorkflowConfig) -> Result<Self>

创建新的动态流程执行器

pub fn with_executor_config( config: WorkflowConfig, executor_config: ExecutorConfig, ) -> Result<Self>

使用自定义执行器配置创建

pub async fn execute( &mut self, context: SharedContext, ) -> Result<ExecutionResult>

执行工作流 - 新的分层架构实现

pub fn get_execution_plan_preview(&self) -> Result<ExecutionPlan>

获取执行计划预览（不执行）

pub fn analyze_workflow_complexity(&self) -> Result<ExecutionComplexity>

分析工作流复杂度

pub fn validate_workflow(&self) -> Result<()>

验证工作流配置

pub fn get_stats(&self) -> &ExecutionStats

获取执行统计信息

pub fn get_workflow_info(&self) -> WorkflowInfo

获取工作流信息

pub fn evaluator(&self) -> &ExpressionEvaluator

获取表达式评估器

pub fn config(&self) -> &WorkflowConfig

获取工作流配置

pub fn executor_status(&self) -> ExecutorStatus

获取执行器状态

pub async fn stop(&mut self) -> Result<()>

停止执行器

Trait Implementations

impl Executor for DynamicFlowExecutor

type Input = Arc<Mutex<FlowContext>>

type Output = ExecutionResult

type Error = Error

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

执行输入并返回结果

fn status(&self) -> ExecutorStatus

获取执行器状态

async fn stop(&mut self) -> Result<(), Self::Error>

停止执行器