Struct MockJobDispatch 

pub struct MockJobDispatch { /* private fields */ }

Records dispatched jobs for later verification.

Implementations

impl MockJobDispatch

pub fn new() -> Self

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

pub async fn dispatch_at<T: Serialize>( &self, job_type: &str, args: T, scheduled_at: DateTime<Utc>, ) -> Result<Uuid>

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

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

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

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

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

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

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

pub fn clear(&self)

pub fn complete_job(&self, job_id: Uuid)

pub fn fail_job(&self, job_id: Uuid)

pub fn cancel_job(&self, job_id: Uuid, reason: Option<String>)

Trait Implementations

impl Default for MockJobDispatch

fn default() -> Self

Returns the “default value” for a type.

impl JobDispatch for MockJobDispatch

fn get_info(&self, _job_type: &str) -> Option<JobInfo>

Get job info by name for auth checking.

fn dispatch_by_name( &self, job_type: &str, args: Value, owner_subject: Option<String>, _tenant_id: Option<Uuid>, ) -> Pin<Box<dyn Future<Output = Result<Uuid>> + Send + '_>>

Dispatch a job by its registered name.

fn dispatch_by_name_at( &self, job_type: &str, args: Value, scheduled_at: DateTime<Utc>, owner_subject: Option<String>, _tenant_id: Option<Uuid>, ) -> Pin<Box<dyn Future<Output = Result<Uuid>> + Send + '_>>

Dispatch a job at a specific time by its registered name.

fn dispatch_in_conn<'a>( &'a self, _conn: &'a mut PgConnection, job_type: &'a str, args: Value, owner_subject: Option<String>, _tenant_id: Option<Uuid>, ) -> Pin<Box<dyn Future<Output = Result<Uuid>> + Send + 'a>>

Dispatch a job on an existing connection — typically the live transaction inside a MutationContext. The insert participates in the surrounding transaction, so the job only becomes visible to workers after commit and is rolled back on failure.

fn dispatch_in_conn_at<'a>( &'a self, _conn: &'a mut PgConnection, job_type: &'a str, args: Value, scheduled_at: DateTime<Utc>, owner_subject: Option<String>, _tenant_id: Option<Uuid>, ) -> Pin<Box<dyn Future<Output = Result<Uuid>> + Send + 'a>>

Dispatch a job at a specific time on an existing connection.

fn cancel( &self, job_id: Uuid, reason: Option<String>, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + '_>>

Request cancellation for a job.