Struct WorkflowEngine 

pub struct WorkflowEngine { /* private fields */ }

工作流引擎统一门面，对齐 design 2.2.2.1。

Implementations

impl WorkflowEngine

pub fn new(config: WorkflowConfig, deps: WorkflowDeps) -> Self

pub async fn validate_definition( &self, text: &str, format: DefinitionFormat, ) -> WorkflowResult<Vec<ValidationIssue>>

pub async fn import_definition( &self, text: &str, format: DefinitionFormat, ) -> WorkflowResult<DefinitionId>

pub async fn export_definition( &self, id: &DefinitionId, format: DefinitionFormat, ) -> WorkflowResult<String>

pub async fn start_instance( &self, flow_key: &str, context: Value, initiator: &str, ) -> WorkflowResult<InstanceSummary>

pub async fn suspend_instance( &self, instance_id: &str, actor: &str, ) -> WorkflowResult<()>

pub async fn resume_instance( &self, instance_id: &str, actor: &str, ) -> WorkflowResult<()>

pub async fn terminate_instance( &self, instance_id: &str, actor: &str, ) -> WorkflowResult<()>

pub async fn query_instance( &self, instance_id: &str, ) -> WorkflowResult<InstanceDetail>

pub async fn query_history( &self, instance_id: &str, ) -> WorkflowResult<Vec<HistoryEntry>>

pub async fn fire_event( &self, instance_id: &str, event: &str, machine: &StateMachineDefinition, payload: Value, ) -> WorkflowResult<TransitionResult>

pub async fn handle_task( &self, task_id: &str, action: TaskAction, comment: Option<String>, actor: &str, definition: &FlowDefinition, ) -> WorkflowResult<TaskHandleResult>

pub async fn query_tasks( &self, candidate: &str, page: PageRequest, ) -> WorkflowResult<PageResult<Task>>