Struct DurableExecution 

pub struct DurableExecution<S: ExecutionStore> { /* private fields */ }

A durable execution workflow

Implementations

impl DurableExecution<MemoryExecutionStore>

pub fn in_memory(execution_id: impl Into<String>) -> Self

Create with in-memory store

impl<S: ExecutionStore> DurableExecution<S>

pub fn new(execution_id: impl Into<String>, store: Arc<S>) -> Self

pub fn with_config(self, config: DurableConfig) -> Self

pub fn add_step<F, Fut>(self, id: impl Into<String>, handler: F) -> Self

where F: Fn() -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<String, String>> + Send + 'static,

Add a step to the execution

pub fn add_step_config(self, step: ExecutionStep) -> Self

Add a pre-configured step

pub async fn run(&self) -> Result<ExecutionResult, DurableError>

Run the execution (resumes from last completed step if interrupted)

pub async fn pause(&self) -> Result<(), DurableError>

Pause the execution (for manual resume later)

pub async fn state(&self) -> Result<Option<ExecutionState>, DurableError>

Get current state

pub async fn reset(&self) -> Result<(), DurableError>

Reset execution to start from beginning