Struct WorkflowExecutor 

pub struct WorkflowExecutor { /* private fields */ }

Executes workflows.

Implementations

impl WorkflowExecutor

pub fn new( registry: Arc<WorkflowRegistry>, pool: PgPool, http_client: CircuitBreakerClient, ) -> Self

Create a new workflow executor.

pub async fn start<I: Serialize>( &self, workflow_name: &str, input: I, owner_subject: Option<String>, ) -> Result<Uuid>

Start a new workflow. Returns immediately with the run_id; workflow executes in the background.

pub async fn resume(&self, run_id: Uuid) -> Result<WorkflowResult>

Resume a workflow from where it left off.

pub async fn resume_from_sleep(&self, run_id: Uuid) -> Result<WorkflowResult>

Resume a workflow after a sleep timer expired.

pub async fn status(&self, run_id: Uuid) -> Result<WorkflowRecord>

Get workflow status.

pub async fn cancel(&self, run_id: Uuid) -> Result<()>

Cancel a workflow and run compensation.

Compensation follows the saga pattern: steps are undone in reverse order of their completion. This ensures that dependencies are respected. For example, if step A created a resource that step B modified, we must undo B’s modification before deleting A’s resource.

Compensation handlers receive the original step result, allowing them to know exactly what to undo (e.g., refund the specific payment ID).

pub async fn save_step(&self, step: &WorkflowStepRecord) -> Result<()>

Save step record.

pub async fn start_by_name( &self, workflow_name: &str, input: Value, owner_subject: Option<String>, ) -> Result<Uuid>

Start a workflow by its registered name with JSON input.

Trait Implementations

impl WorkflowDispatch for WorkflowExecutor

fn get_info(&self, workflow_name: &str) -> Option<WorkflowInfo>

Get workflow info by name for auth checking.

fn start_by_name( &self, workflow_name: &str, input: Value, owner_subject: Option<String>, ) -> Pin<Box<dyn Future<Output = Result<Uuid>> + Send + '_>>

Start a workflow by its registered name.