Struct PauseResumeController 

pub struct PauseResumeController { /* private fields */ }

High-level controller for pausing and resuming workflows by numeric ID.

Internally maps numeric workflow IDs to PauseCheckpoints stored in a PauseCheckpointStore. Numeric IDs are converted to strings for compatibility with the checkpoint store’s string-keyed API.

Example

use oximedia_workflow::pause_resume::PauseResumeController;

let mut ctrl = PauseResumeController::new();
ctrl.pause(42);
assert!(ctrl.is_paused(42));
ctrl.resume(42);
assert!(!ctrl.is_paused(42));

Implementations

impl PauseResumeController

pub fn new() -> Self

Create an empty controller.

pub fn pause(&mut self, workflow_id: u64)

Pause a workflow by its numeric ID.

If the workflow is already paused this is a no-op (the checkpoint is updated with a fresh timestamp by replacing the entry).

pub fn resume(&mut self, workflow_id: u64)

Resume a workflow by removing its pause checkpoint.

If the workflow is not currently paused this is a no-op.

pub fn is_paused(&self, workflow_id: u64) -> bool

Return true if a pause checkpoint exists for the given workflow ID.

pub fn paused_count(&self) -> usize

Return the number of currently paused workflows.

pub fn paused_ids(&self) -> Vec<u64>

List all currently paused workflow IDs.

Trait Implementations

impl Debug for PauseResumeController

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

Formats the value using the given formatter.

impl Default for PauseResumeController

fn default() -> PauseResumeController

Returns the “default value” for a type.