Struct MockJobDispatch 

pub struct MockJobDispatch { /* private fields */ }

Mock job dispatcher for testing.

Records dispatched jobs for later verification.

Example

let dispatch = MockJobDispatch::new();
dispatch.dispatch("send_email", json!({"to": "test@example.com"})).await?;

dispatch.assert_dispatched("send_email");
dispatch.assert_dispatched_with("send_email", |args| {
    args["to"] == "test@example.com"
});

Implementations

impl MockJobDispatch

pub fn new() -> MockJobDispatch

Create a new mock job dispatcher.

pub async fn dispatch<T>( &self, job_type: &str, args: T, ) -> Result<Uuid, ForgeError>

where T: Serialize,

Dispatch a job (records for later verification).

pub fn dispatched_jobs(&self) -> Vec<DispatchedJob>

Get all dispatched jobs.

pub fn jobs_of_type(&self, job_type: &str) -> Vec<DispatchedJob>

Get jobs of a specific type.

pub fn assert_dispatched(&self, job_type: &str)

Assert that a job type was dispatched.

pub fn assert_dispatched_with<F>(&self, job_type: &str, predicate: F)

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

Assert that a job was dispatched with matching arguments.

pub fn assert_not_dispatched(&self, job_type: &str)

Assert that a job type was not dispatched.

pub fn assert_dispatch_count(&self, job_type: &str, expected: usize)

Assert that a specific number of jobs were dispatched.

pub fn clear(&self)

Clear all recorded jobs.

pub fn complete_job(&self, job_id: Uuid)

Mark a job as completed (for test simulation).

pub fn fail_job(&self, job_id: Uuid)

Mark a job as failed (for test simulation).

Trait Implementations

impl Default for MockJobDispatch

fn default() -> MockJobDispatch

Returns the “default value” for a type.