Struct SagaManager 

pub struct SagaManager { /* private fields */ }

Sagaマネージャー

Implementations

impl SagaManager

pub fn new() -> Self

pub async fn register_pattern( &self, pattern: AdvancedSagaPattern, ) -> Result<(), WorkflowError>

Sagaパターンを登録

pub async fn start_saga( &self, pattern_name: &str, workflow_id: WorkflowExecutionId, inputs: HashMap<String, Value>, ) -> Result<String, WorkflowError>

Saga実行を開始

pub async fn record_transaction( &self, saga_id: &str, transaction: SagaTransaction, ) -> Result<(), WorkflowError>

トランザクションを記録

pub async fn record_compensation( &self, saga_id: &str, compensation: SagaCompensation, ) -> Result<(), WorkflowError>

補償を記録

pub async fn update_saga_status( &self, saga_id: &str, status: SagaStatus, ) -> Result<(), WorkflowError>

Saga状態を更新

pub async fn get_saga_context(&self, saga_id: &str) -> Option<SagaContext>

Sagaコンテキストを取得

pub async fn get_compensable_transactions( &self, saga_id: &str, ) -> Result<Vec<SagaTransaction>, WorkflowError>

補償が必要なトランザクションを取得

pub async fn get_compensation_order( &self, saga_id: &str, policy: &CompensationPolicy, ) -> Result<Vec<String>, WorkflowError>

Sagaの補償実行順序を決定

pub async fn resolve_dependencies( &self, pattern: &AdvancedSagaPattern, completed: &[String], ) -> Vec<String>

Sagaの依存関係を解決

pub fn get_metrics(&self) -> &SagaMetrics

Sagaのメトリクスを取得

pub async fn get_running_sagas(&self) -> Vec<SagaContext>

実行中のSagaを取得

pub async fn detect_timed_out_sagas(&self) -> Vec<String>

タイムアウトしたSagaを検出

pub async fn cleanup_saga(&self, saga_id: &str) -> Result<(), WorkflowError>

Sagaをクリーンアップ