Struct WorkflowStateManager 

pub struct WorkflowStateManager { /* private fields */ }

ワークフロー状態マネージャー - MVCCベースの実装

Implementations

impl WorkflowStateManager

pub fn new() -> Self

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

MVCCベースのワークフロー実行作成

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

指定されたTxId時点での実行状態を取得（MVCC対応）

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

最新バージョンの実行状態を取得

pub async fn update_execution( &self, execution: WorkflowExecution, ) -> Result<TxId, WorkflowError>

MVCCベースの実行状態更新

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

実行のバージョン履歴を取得

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

スナップショット作成（古いバージョンのクリーンアップ）

pub async fn get_running_executions(&self) -> Vec<WorkflowExecution>

実行中のワークフロー一覧を取得

pub async fn add_execution_event( &self, execution_id: &WorkflowExecutionId, event: ExecutionEvent, ) -> Result<TxId, WorkflowError>

実行イベントを追加