Struct WorkflowExecutor 

pub struct WorkflowExecutor {
    pub persistence: Arc<dyn PersistenceProvider>,
    pub lock_provider: Arc<dyn DistributedLockProvider>,
    pub queue_provider: Arc<dyn QueueProvider>,
    pub lifecycle: Option<Arc<dyn LifecyclePublisher>>,
    pub search: Option<Arc<dyn SearchIndex>>,
}

The core workflow executor. Processes a single workflow instance per execute() call.

Fields

persistence: Arc<dyn PersistenceProvider>

lock_provider: Arc<dyn DistributedLockProvider>

queue_provider: Arc<dyn QueueProvider>

lifecycle: Option<Arc<dyn LifecyclePublisher>>

search: Option<Arc<dyn SearchIndex>>

Implementations

impl WorkflowExecutor

pub fn new( persistence: Arc<dyn PersistenceProvider>, lock_provider: Arc<dyn DistributedLockProvider>, queue_provider: Arc<dyn QueueProvider>, ) -> Self

pub fn with_lifecycle(self, lifecycle: Arc<dyn LifecyclePublisher>) -> Self

pub fn with_search(self, search: Arc<dyn SearchIndex>) -> Self

pub async fn execute( &self, workflow_id: &str, definition: &WorkflowDefinition, step_registry: &StepRegistry, ) -> Result<()>

Execute a single workflow instance.

1. Acquire lock
2. Load instance
3. Find runnable pointers
4. Execute each runnable pointer’s step
5. Process results
6. Check for completion
7. Persist
8. Release lock