Struct StateSnapshot 

pub struct StateSnapshot<S>
where
    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 for StateSnapshot<S>

where S: Clone + State,

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 for StateSnapshot<S>

where S: Debug + State,

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

Formats the value using the given formatter.