Struct ExtendedWorkflowEngine 

pub struct ExtendedWorkflowEngine { /* private fields */ }

Extended workflow engine - builds on core workflow functionality

Implementations

impl ExtendedWorkflowEngine

pub fn builder() -> WorkflowEngineBuilder

pub fn activity_registry(&self) -> &Arc<ActivityRegistry>

Get activity registry for registering activities

pub async fn start_workflow( &mut self, workflow_ir: &WorkflowIR, inputs: HashMap<String, Value>, ) -> Result<WorkflowExecutionId, WorkflowError>

Start workflow execution

pub async fn wait_for_completion( &self, execution_id: WorkflowExecutionId, timeout: Option<Duration>, ) -> Result<WorkflowResult, WorkflowError>

Wait for workflow completion

pub async fn get_execution_status( &self, execution_id: &WorkflowExecutionId, ) -> Result<Option<ExecutionStatus>, WorkflowError>

Get workflow execution status

pub async fn get_execution( &self, execution_id: &WorkflowExecutionId, ) -> Result<Option<WorkflowExecution>, WorkflowError>

Get workflow execution details

pub async fn list_running_executions( &self, ) -> Result<Vec<WorkflowExecution>, WorkflowError>

List running executions

pub async fn cancel_execution( &self, execution_id: &WorkflowExecutionId, ) -> Result<(), WorkflowError>

Cancel workflow execution

pub async fn get_execution_at_tx( &self, execution_id: &WorkflowExecutionId, tx_id: TxId, ) -> Option<WorkflowExecution>

Phase 2: Get workflow execution at specific transaction

pub async fn get_execution_history( &self, execution_id: &WorkflowExecutionId, ) -> Vec<(TxId, WorkflowExecution)>

Phase 2: Get execution history (all versions)

pub async fn get_event_history( &self, execution_id: &WorkflowExecutionId, ) -> Result<Vec<ExecutionEvent>, WorkflowError>

Phase 2: Get full event history

pub async fn rebuild_execution_from_events( &self, execution_id: &WorkflowExecutionId, ) -> Result<Option<WorkflowExecution>, WorkflowError>

Phase 2: Rebuild execution from events (for recovery)

pub async fn create_snapshot( &self, execution_id: &WorkflowExecutionId, ) -> Result<(), WorkflowError>

Phase 2: Create manual snapshot

pub async fn restore_from_snapshot( &self, execution_id: &WorkflowExecutionId, ) -> Result<Option<WorkflowExecution>, WorkflowError>

Phase 2: Restore from snapshot

pub async fn get_performance_stats(&self) -> HashMap<String, usize>

Phase 2: Get performance statistics

pub fn event_sourcing(&self) -> &Arc<EventSourcingManager>

Phase 2: Access event sourcing manager

pub fn snapshot_manager(&self) -> &Arc<SnapshotManager>

Phase 2: Access snapshot manager

pub fn enable_distributed_execution( &mut self, local_node_id: String, load_balancer: Arc<dyn LoadBalancer>, )

Phase 2: Enable distributed execution

pub async fn submit_distributed_workflow( &self, execution_id: WorkflowExecutionId, ) -> Result<String, WorkflowError>

Phase 2: Submit workflow for distributed execution

pub async fn get_cluster_health(&self) -> Result<ClusterHealth, WorkflowError>

Phase 2: Get cluster health

pub fn distributed_execution_manager( &self, ) -> Option<&Arc<DistributedExecutionManager>>

Phase 2: Get distributed execution manager

pub fn is_distributed_enabled(&self) -> bool

Phase 2: Check if distributed execution is enabled