Struct WorkflowDefinitions 

pub struct WorkflowDefinitions { /* private fields */ }

Contains workflow registrations in a form ready for execution by workers.

Implementations

impl WorkflowDefinitions

pub fn new() -> Self

Creates a new empty WorkflowDefinitions.

pub fn register_workflow<W: WorkflowImplementation>( &mut self, ) -> Result<&mut Self, WorkflowRegistrationError>

where <W::Run as WorkflowDefinition>::Input: Send,

Register a workflow implementation.

Returns an error if a workflow with the same type is already registered.

pub fn register_workflow_run_with_factory<W, F>( &mut self, user_factory: F, ) -> Result<&mut Self, WorkflowRegistrationError>

where W: WorkflowImplementation, <W::Run as WorkflowDefinition>::Input: Send, F: Fn() -> W + Send + Sync + 'static,

Register a workflow with a custom factory for instance creation.

Returns an error if a workflow with the same type is already registered, or if the workflow type defines an #[init] method.

pub fn is_empty(&self) -> bool

Check if any workflows are registered.

pub fn workflow_definitions( &self, ) -> impl Iterator<Item = &WorkflowDefinitionDescriptor> + '_

Returns an iterator over registered workflow definitions.

Trait Implementations

impl Clone for WorkflowDefinitions

fn clone(&self) -> WorkflowDefinitions

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkflowDefinitions

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

Formats the value using the given formatter.

impl Default for WorkflowDefinitions

fn default() -> WorkflowDefinitions

Returns the “default value” for a type.