Struct MockWorkflowDispatch 

pub struct MockWorkflowDispatch { /* private fields */ }

Records started workflows for later verification.

Implementations

impl MockWorkflowDispatch

pub fn new() -> MockWorkflowDispatch

pub async fn start<T>( &self, workflow_name: &str, input: T, ) -> Result<Uuid, ForgeError>

where T: Serialize,

pub fn started_workflows(&self) -> Vec<StartedWorkflow>

pub fn workflows_named(&self, name: &str) -> Vec<StartedWorkflow>

pub fn assert_started(&self, workflow_name: &str)

pub fn assert_started_with<F>(&self, workflow_name: &str, predicate: F)

where F: Fn(&Value) -> bool,

pub fn assert_not_started(&self, workflow_name: &str)

pub fn assert_start_count(&self, workflow_name: &str, expected: usize)

pub fn clear(&self)

pub fn complete_workflow(&self, run_id: Uuid)

pub fn fail_workflow(&self, run_id: Uuid)

Trait Implementations

impl Default for MockWorkflowDispatch

fn default() -> MockWorkflowDispatch

Returns the “default value” for a type.

impl WorkflowDispatch for MockWorkflowDispatch

fn get_info(&self, _workflow_name: &str) -> Option<WorkflowInfo>

Get workflow info by name for auth checking.

fn start_by_name( &self, workflow_name: &str, input: Value, _owner_subject: Option<String>, _trace_id: Option<String>, ) -> Pin<Box<dyn Future<Output = Result<Uuid, ForgeError>> + Send + '_>>

Start a workflow by its registered name.

fn start_in_conn<'a>( &'a self, _conn: &'a mut PgConnection, workflow_name: &'a str, input: Value, _owner_subject: Option<String>, _trace_id: Option<String>, ) -> Pin<Box<dyn Future<Output = Result<Uuid, ForgeError>> + Send + 'a>>

Start a workflow on an existing connection — typically the live transaction inside a MutationContext. The run row and its $workflow_resume job are written in the same transaction so the worker only picks the run up after commit.