WorkflowEngineAdapter

Trait WorkflowEngineAdapter 

Source
pub trait WorkflowEngineAdapter: Send + Sync {
    // Required methods
    fn exportworkflow(&self, workflow: &Workflow) -> Result<String>;
    fn importworkflow(&self, definition: &str) -> Result<Workflow>;
    fn submit(&self, workflow: &Workflow) -> Result<String>;
    fn get_status(&self, executionid: &str) -> Result<WorkflowStatus>;
    fn cancel(&self, executionid: &str) -> Result<()>;
}
Expand description

Trait for external workflow engine adapters

Required Methods§

Source

fn exportworkflow(&self, workflow: &Workflow) -> Result<String>

Convert internal workflow to engine-specific format

Source

fn importworkflow(&self, definition: &str) -> Result<Workflow>

Import workflow from engine-specific format

Source

fn submit(&self, workflow: &Workflow) -> Result<String>

Submit workflow for execution

Source

fn get_status(&self, executionid: &str) -> Result<WorkflowStatus>

Get execution status

Source

fn cancel(&self, executionid: &str) -> Result<()>

Cancel execution

Implementors§