Struct WorkflowEngine 

pub struct WorkflowEngine { /* private fields */ }

工作流引擎

Implementations

impl WorkflowEngine

pub fn new(definition: WorkflowDef) -> Result<Self>

创建新的工作流引擎

pub fn with_executor(self, executor: Arc<dyn TaskExecutor>) -> Self

设置任务执行器（旧接口）

pub fn with_executor_factory(self, factory: ExecutorFactory) -> Self

设置执行器工厂

pub fn with_proxy_executor( self, executor: Arc<dyn ProxyToolExecutor>, tool_defs: Vec<ProxyToolDef>, ) -> Self

设置代理工具执行器

pub fn register_node_executor( self, task_type: &str, executor: Arc<dyn NodeExecutor>, ) -> Self

注册节点执行器

pub fn add_listener(&mut self, listener: Box<dyn EventListener>)

添加事件监听器

pub async fn run( &self, inputs: HashMap<String, Value>, ) -> Result<WorkflowContext>

运行工作流

pub fn definition(&self) -> &WorkflowDef

获取工作流定义