Struct SessionCheckpointSink 

pub struct SessionCheckpointSink<'a, S: WorkflowState = State>
where
    S::Checkpoint: Debug,
{ /* private fields */ }

Session 的 Checkpoint Sink — 将 checkpoint 事件写入 FrameStack。

这是 CheckpointSink SPI 的实现之一。Engine 通过借用 &dyn CheckpointSink<S> 通知到达恢复边界，SessionCheckpointSink 负责将 Frame 推入 FrameStack。

设计原则

Engine 不知道 FrameStack 的存在，只调用 sink.on_checkpoint(&state, &frame_info)。 SessionCheckpointSink 是适配器，将通用的 checkpoint 事件转换为 FrameStack 操作。

Implementations

impl<'a, S: WorkflowState> SessionCheckpointSink<'a, S>

where S::Checkpoint: Debug,

pub fn new( frame_stack: &'a mut FrameStack<S>, graph_name: impl Into<String>, ) -> Self

创建 SessionCheckpointSink，绑定到 FrameStack。

Trait Implementations

impl<S: WorkflowState> CheckpointSink<S> for SessionCheckpointSink<'_, S>

where S::Checkpoint: Debug + Sync,

fn on_checkpoint(&mut self, state: &S, frame: &FrameInfo)

节点完成，State 已 commit。