Struct CheckpointData 

pub struct CheckpointData<S: State> {
    pub state: S,
    pub next_nodes: Vec<String>,
    pub step: u32,
    pub interrupted_node: Option<String>,
    pub phase_state: PhaseStateStore,
    pub checkpoint_id: Option<String>,
}

Internal wrapper for checkpoint serialization.

Bincode-serialized into the opaque bytes stored by Checkpointer. The checkpointer sees bytes; this struct gives them meaning.

Fields

state: S

Full state at the checkpoint.

next_nodes: Vec<String>

Which nodes are scheduled to run next.

step: u32

Which superstep this checkpoint was taken at.

interrupted_node: Option<String>

Which node was interrupted (if this checkpoint is from an interrupt). Used by resume() to validate the resume target.

phase_state: PhaseStateStore

Serialized phase state for nodes using the interrupt/phase system. Survives checkpoint serialization so phases resume correctly.

checkpoint_id: Option<String>

The checkpoint ID this data was loaded from (for parent lineage). Not serialized — set by the loading code.

Trait Implementations

impl<'de, S: State> Deserialize<'de> for CheckpointData<S>

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<S: State> Serialize for CheckpointData<S>

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

where __S: Serializer,

Serialize this value into the given Serde serializer.