Struct RollbackManager 

pub struct RollbackManager { /* private fields */ }

Manages execution snapshots and rollback operations

Implementations

impl RollbackManager

pub fn new(max_snapshots: usize) -> Self

Create a new rollback manager

Arguments

• max_snapshots - Maximum number of snapshots to keep

pub fn with_auto_snapshot(self, interval: usize) -> Self

Enable automatic snapshots every N nodes

pub fn push_snapshot(&mut self, snapshot: ExecutionSnapshot)

Push a new snapshot

If max_snapshots is reached, the oldest snapshot is removed.

pub fn create_snapshot(&mut self, ctx: &ExecutionContext) -> Uuid

Create and push a snapshot from an execution context

pub fn create_labeled_snapshot( &mut self, ctx: &ExecutionContext, label: impl Into<String>, ) -> Uuid

Create a labeled snapshot

pub fn on_node_execute( &mut self, ctx: &ExecutionContext, node_id: NodeId, ) -> Option<Uuid>

Called when a node is about to execute

Creates automatic snapshots if enabled.

pub fn rollback(&mut self, ctx: &mut ExecutionContext) -> RollbackResult

Rollback to the most recent snapshot

pub fn rollback_to( &mut self, ctx: &mut ExecutionContext, snapshot_id: Uuid, ) -> RollbackResult

Rollback to a specific snapshot by ID

pub fn rollback_n( &mut self, ctx: &mut ExecutionContext, steps: usize, ) -> RollbackResult

Rollback N steps in history

• rollback_n(1) returns to the most recent snapshot (index 0)
• rollback_n(2) returns to 2 snapshots ago (index 1)
• rollback_n(3) returns to 3 snapshots ago (index 2)

Note: “Steps” refers to how many states back in history to go, where each snapshot is one state.

pub fn latest_snapshot(&self) -> Option<&ExecutionSnapshot>

Get the most recent snapshot

pub fn get_snapshot(&self, id: Uuid) -> Option<&ExecutionSnapshot>

Get a snapshot by ID

pub fn list_snapshots(&self) -> Vec<&ExecutionSnapshot>

List all snapshots (newest first)

pub fn snapshot_count(&self) -> usize

Get the number of available snapshots

pub fn clear(&mut self)

Clear all snapshots

pub fn prune_before(&mut self, timestamp: DateTime<Utc>) -> usize

Remove snapshots older than a timestamp

pub fn summary(&self) -> RollbackSummary

Get summary of snapshot history

Trait Implementations

impl Clone for RollbackManager

fn clone(&self) -> RollbackManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RollbackManager

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

Formats the value using the given formatter.

impl Default for RollbackManager

fn default() -> Self

Returns the “default value” for a type.