Struct MockWorkflowDispatch 

pub struct MockWorkflowDispatch { /* private fields */ }

Mock workflow dispatcher for testing.

Records started workflows for later verification.

Example

let dispatch = MockWorkflowDispatch::new();
dispatch.start("onboarding", json!({"user_id": "123"})).await?;

dispatch.assert_started("onboarding");

Implementations

impl MockWorkflowDispatch

pub fn new() -> MockWorkflowDispatch

Create a new mock workflow dispatcher.

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

where T: Serialize,

Start a workflow (records for later verification).

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

Get all started workflows.

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

Get workflows of a specific name.

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

Assert that a workflow was started.

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

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

Assert that a workflow was started with matching input.

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

Assert that a workflow was not started.

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

Assert that a specific number of workflows were started.

pub fn clear(&self)

Clear all recorded workflows.

pub fn complete_workflow(&self, run_id: Uuid)

Mark a workflow as completed (for test simulation).

pub fn fail_workflow(&self, run_id: Uuid)

Mark a workflow as failed (for test simulation).

Trait Implementations

impl Default for MockWorkflowDispatch

fn default() -> MockWorkflowDispatch

Returns the “default value” for a type.