Struct WorkflowCheckpoint 

pub struct WorkflowCheckpoint { /* private fields */ }

Stable handle binding one workflow checkpoint identity to a store.

Implementations

impl WorkflowCheckpoint

pub fn new(store: Arc<dyn CheckpointStore>) -> Self

Creates a new workflow checkpoint handle.

pub fn existing(id: CheckpointId, store: Arc<dyn CheckpointStore>) -> Self

Reconnects to an existing workflow checkpoint.

pub fn distributed(store: Arc<dyn WorkflowStore>, lease: WorkflowLease) -> Self

Binds a distributed checkpoint to the current fenced workflow lease.

pub const fn id(&self) -> CheckpointId

Returns the stable checkpoint identity.

pub fn load( &self, ) -> Result<(Checkpoint, WorkflowCheckpointState), CheckpointError>

Loads and validates the latest typed workflow state.

Errors

Returns CheckpointError for storage or payload failures.

pub async fn load_async( &self, ) -> Result<(Checkpoint, WorkflowCheckpointState), CheckpointError>

Loads and validates either a local or distributed checkpoint.

Errors

Returns CheckpointError for ownership, storage, or payload failures.

Trait Implementations

impl Clone for WorkflowCheckpoint

fn clone(&self) -> WorkflowCheckpoint

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkflowCheckpoint

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

Formats the value using the given formatter.