Struct CheckpointConfig 

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

Checkpoint 保存配置 — 三层策略。

CheckpointConfig
  ├── trigger:    何时保存（EveryNode / BarrierOnly / Manual / OnMutation）
  ├── retention:  保留多少个（KeepAll / KeepLatest(N) / TimeBased）
  ├── save_fn:    保存回调
  └── store:      存储后端引用（用于 prune）

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

创建 CheckpointConfig。

save_fn 接收 (Checkpoint<S>, TraceId) 并异步保存。 通常由调用方组合 TypedCheckpointStore + SerdeCheckpointCodec 构造。

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

设置存储后端引用（用于 prune）。

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

向后兼容 — 设置旧的 CheckpointPolicy（自动转换为 TriggerPolicy）。

pub fn should_save(&self, has_mutations: bool, is_barrier: bool) -> bool

根据策略判断是否应该保存。

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

执行保留策略（prune）。