Struct TestJobContext 

pub struct TestJobContext {
    pub job_id: Uuid,
    pub job_type: String,
    pub attempt: u32,
    pub max_attempts: u32,
    pub auth: AuthContext,
    /* private fields */
}

Test context for job functions.

Fields

job_id: Uuid

job_type: String

attempt: u32

max_attempts: u32

auth: AuthContext

Implementations

impl TestJobContext

pub fn builder(job_type: impl Into<String>) -> TestJobContextBuilder

Create a new builder.

pub fn db(&self) -> Option<&PgPool>

Get the database pool (if available).

pub fn http(&self) -> &MockHttp

Get the mock HTTP client.

pub fn progress(&self, percent: u8, message: impl Into<String>) -> Result<()>

Report job progress.

pub fn progress_updates(&self) -> Vec<TestProgressUpdate>

Get all progress updates.

pub fn saved(&self) -> Value

Get all saved job data.

Returns the in-memory data that was written via save().

pub fn save(&self, key: &str, value: Value) -> Result<()>

Save a key-value pair to job data.

Merges key into the saved data object. Use saved() to read it back in assertions.

pub fn is_retry(&self) -> bool

Check if this is a retry attempt.

pub fn is_last_attempt(&self) -> bool

Check if this is the last attempt.

pub async fn heartbeat(&self) -> Result<()>

Simulate heartbeat (no-op in tests, but records the intent).

pub fn is_cancel_requested(&self) -> Result<bool>

Check if cancellation has been requested.

pub fn check_cancelled(&self) -> Result<()>

Return an error if cancellation has been requested.

Use this in job handlers to check for cancellation and exit early.

pub fn request_cancellation(&self)

Request cancellation (for testing cancellation flows).

After calling this, is_cancel_requested() returns true and check_cancelled() returns an error.

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

Buffer a sub-job dispatch (mirrors JobContext::dispatch_job).

pub fn start_workflow<T: Serialize>( &self, workflow_name: &str, args: &T, ) -> Result<Uuid>

Buffer a workflow start (mirrors JobContext::start_workflow).

pub fn dispatched_jobs(&self) -> Vec<(String, Value, Uuid)>

Get all dispatched sub-jobs for assertions.

pub fn started_workflows(&self) -> Vec<(String, Value, Uuid)>

Get all started workflows for assertions.

pub fn env_mock(&self) -> &MockEnvProvider

Get the mock env provider for verification.

Trait Implementations

impl EnvAccess for TestJobContext

fn env_provider(&self) -> &dyn EnvProvider

fn env(&self, key: &str) -> Option<String>

fn env_or(&self, key: &str, default: &str) -> String

fn env_require(&self, key: &str) -> Result<String>

fn env_parse<T: FromStr>(&self, key: &str) -> Result<T>

where T::Err: Display,

fn env_parse_or<T: FromStr>(&self, key: &str, default: T) -> Result<T>

where T::Err: Display,

Returns the default when unset; errors only if the variable is set but unparseable.

fn env_contains(&self, key: &str) -> bool