Struct CheckpointConfig 

pub struct CheckpointConfig<S: WorkflowState> {
    pub trigger: TriggerPolicy,
    pub retention: RetentionPolicy,
    /* private fields */
}

Checkpoint 保存配置 — 传入 run_execution_loop 即可启用自动保存。

Fields

trigger: TriggerPolicy

触发策略

retention: RetentionPolicy

保留策略

Implementations

impl<S: WorkflowState> CheckpointConfig<S>

pub fn new( save_fn: impl Fn(Checkpoint<S>, TraceId) -> Pin<Box<dyn Future<Output = Result<(), CheckpointStoreError>> + Send>> + Send + Sync + 'static, graph_hash: u64, ) -> Self

pub fn with_trigger(self, trigger: TriggerPolicy) -> Self

pub fn with_retention(self, retention: RetentionPolicy) -> Self

pub fn with_store(self, store: Arc<dyn BlobCheckpointStore>) -> Self

pub fn with_policy(self, policy: CheckpointPolicy) -> Self

pub async fn apply_retention( &self, trace_id: &TraceId, ) -> Result<(), CheckpointStoreError>