Struct StateSnapshot 

pub struct StateSnapshot<S: State> {
    pub values: S,
    pub next: Vec<String>,
    pub config: RunnableConfig,
    pub metadata: CheckpointMetadata,
    pub created_at: String,
    pub parent_config: Option<RunnableConfig>,
    pub tasks: Vec<PregelTaskInfo>,
}

State snapshot at a specific checkpoint

Represents the deserialized, fully-hydrated execution state at a checkpoint.

Type Parameters

• S - State type implementing the crate::State trait

Fields

values: S

The complete state values

next: Vec<String>

Next nodes to execute

config: RunnableConfig

Configuration with checkpoint_id for time-travel

metadata: CheckpointMetadata

Checkpoint metadata

created_at: String

ISO 8601 creation timestamp

parent_config: Option<RunnableConfig>

Parent checkpoint configuration

tasks: Vec<PregelTaskInfo>

Task information for current superstep

Trait Implementations

impl<S: Clone + State> Clone for StateSnapshot<S>

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S: Debug + State> Debug for StateSnapshot<S>

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

Formats the value using the given formatter.