Struct WorkflowExecutor 

pub struct WorkflowExecutor { /* private fields */ }

Executes workflows.

Implementations

impl WorkflowExecutor

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

Create a new workflow executor.

pub async fn start<I: Serialize>( &self, workflow_name: &str, input: I, ) -> 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.

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

Save step record.

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

Start a workflow by its registered name with JSON input.

Trait Implementations

impl WorkflowDispatch for WorkflowExecutor

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

Start a workflow by its registered name.