Struct WorkflowRegistry 

pub struct WorkflowRegistry { /* private fields */ }

Registry of all workflows, supporting multiple versions per workflow name.

Implementations

impl WorkflowRegistry

pub fn new() -> Self

Create a new empty registry.

pub fn register<W: ForgeWorkflow>(&mut self)

where W::Input: DeserializeOwned, W::Output: Serialize,

Register a workflow handler.

pub fn get_active(&self, name: &str) -> Option<&WorkflowEntry>

Get the active version entry for a workflow by name. Used when starting new runs.

pub fn get_version(&self, name: &str, version: &str) -> Option<&WorkflowEntry>

Get a specific workflow version. Used when resuming runs pinned to a specific version.

pub fn get(&self, name: &str) -> Option<&WorkflowEntry>

Get a workflow entry by name (returns the active version). Backward-compatible with code that only knows the workflow name.

pub fn has_version_with_signature( &self, name: &str, version: &str, signature: &str, ) -> bool

Check if a specific version+signature combination is available.

pub fn validate_resume( &self, name: &str, version: &str, signature: &str, ) -> Result<&WorkflowEntry, ResumeBlockReason>

Validate that a run can be safely resumed. Returns the matching entry, or a blocking reason.

pub fn list(&self) -> impl Iterator<Item = &WorkflowEntry>

List all registered workflow entries.

pub fn len(&self) -> usize

Get the number of registered workflow entries (all versions).

pub fn is_empty(&self) -> bool

Check if the registry is empty.

pub fn names(&self) -> impl Iterator<Item = &str>

Get all workflow names (deduplicated).

pub fn definitions(&self) -> Vec<&WorkflowInfo>

Get all registered definitions for startup persistence.

Trait Implementations

impl Clone for WorkflowRegistry

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for WorkflowRegistry

fn default() -> WorkflowRegistry

Returns the “default value” for a type.