pub struct SnapshotManager { /* private fields */ }
Expand description
スナップショットマネージャー(パフォーマンス最適化) - Phase 2
Implementations§
Source§impl SnapshotManager
impl SnapshotManager
pub fn new( store: Arc<dyn WorkflowStore>, event_sourcing: Arc<EventSourcingManager>, ) -> Self
pub fn with_config(self, snapshot_interval: usize, max_snapshots: usize) -> Self
Sourcepub async fn needs_snapshot(
&self,
execution_id: &WorkflowExecutionId,
) -> Result<bool, WorkflowError>
pub async fn needs_snapshot( &self, execution_id: &WorkflowExecutionId, ) -> Result<bool, WorkflowError>
スナップショットが必要かチェック
Sourcepub async fn create_snapshot(
&self,
execution: &WorkflowExecution,
) -> Result<(), WorkflowError>
pub async fn create_snapshot( &self, execution: &WorkflowExecution, ) -> Result<(), WorkflowError>
最適化されたスナップショットを作成
Sourcepub async fn cleanup_old_snapshots(
&self,
execution_id: &WorkflowExecutionId,
) -> Result<(), WorkflowError>
pub async fn cleanup_old_snapshots( &self, execution_id: &WorkflowExecutionId, ) -> Result<(), WorkflowError>
古いスナップショットをクリーンアップ
Sourcepub async fn restore_from_snapshot(
&self,
execution_id: &WorkflowExecutionId,
) -> Result<Option<WorkflowExecution>, WorkflowError>
pub async fn restore_from_snapshot( &self, execution_id: &WorkflowExecutionId, ) -> Result<Option<WorkflowExecution>, WorkflowError>
ワークフロー実行をスナップショットから高速復元
Sourcepub async fn get_performance_stats(&self) -> HashMap<String, usize>
pub async fn get_performance_stats(&self) -> HashMap<String, usize>
パフォーマンス統計を取得
Auto Trait Implementations§
impl Freeze for SnapshotManager
impl !RefUnwindSafe for SnapshotManager
impl Send for SnapshotManager
impl Sync for SnapshotManager
impl Unpin for SnapshotManager
impl !UnwindSafe for SnapshotManager
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more