Struct EventSourcingManager 

pub struct EventSourcingManager { /* private fields */ }

イベントソーシングマネージャー - 完全なイベントドリブン永続化

Implementations

impl EventSourcingManager

pub fn new(store: Arc<dyn WorkflowStore>) -> Self

pub fn with_snapshot_config( self, snapshot_interval: usize, max_versions: usize, ) -> Self

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

ワークフロー実行をイベントから再構築

pub async fn record_event( &self, execution_id: &WorkflowExecutionId, event_type: ExecutionEventType, payload: HashMap<String, Value>, ) -> Result<(), WorkflowError>

ワークフローイベントを記録（スナップショット最適化付き）

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

スナップショットが必要かチェック

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

スナップショットを作成（最新の実行状態を保存）

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

古いイベントをクリーンアップ

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

ワークフロー実行の完全なイベント履歴を取得

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

イベントベースのワークフロー状態再構築