Struct Frame 

pub struct Frame<S: WorkflowState = State> {
    pub graph_id: String,
    pub node_id: String,
    pub state: S::Checkpoint,
    pub cursor: usize,
}

向后兼容 — CheckpointPolicy 已迁移至 checkpoint_policy 模块。 v0.5 使用 TriggerPolicy + RetentionPolicy 替代。 执行帧 — 保存单个 Graph 的执行位置。

可序列化 — 用于 SessionCheckpoint 持久化。

Fields

graph_id: String

图 ID

node_id: String

当前节点 ID

state: S::Checkpoint

状态快照（P0-1: 使用 Checkpoint 关联类型，可序列化）

cursor: usize

执行游标（节点索引或步骤数）

Implementations

impl<S: WorkflowState> Frame<S>

pub fn new(graph_id: String, node_id: String, state: &S, cursor: usize) -> Self

从 Runtime State 创建 Frame（使用 snapshot() 投影）。

Trait Implementations

impl<S: Clone + WorkflowState> Clone for Frame<S>

where S::Checkpoint: Clone,

fn clone(&self) -> Frame<S>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<S: WorkflowState> Debug for Frame<S>

where S::Checkpoint: Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de, S: WorkflowState> Deserialize<'de> for Frame<S>

where S::Checkpoint: Deserialize<'de>,

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<S: WorkflowState> Serialize for Frame<S>

where S::Checkpoint: Serialize,

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.