Struct TestClient 

pub struct TestClient { /* private fields */ }

Test client for working with jobs in tests.

Provides helper methods for inserting jobs and executing them synchronously.

Implementations

impl TestClient

pub async fn from_pool(pool: PgPool) -> Self

Create a test client from an existing pool.

pub fn pool(&self) -> &PgPool

Get the underlying pool.

pub async fn migrate(&self) -> Result<(), AwaError>

Run migrations (call this in test setup).

pub async fn clean(&self) -> Result<(), AwaError>

Clean the awa schema (for test isolation).

pub async fn insert(&self, args: &impl JobArgs) -> Result<JobRow, AwaError>

Insert a job.

pub async fn work_one<W: Worker>( &self, worker: &W, ) -> Result<WorkResult, AwaError>

Claim and execute a single job of type T using the given worker.

This overload does NOT filter by queue, so it may pick up jobs from any queue. Prefer work_one_in_queue for test isolation.

pub async fn work_one_in_queue<W: Worker>( &self, worker: &W, queue: Option<&str>, ) -> Result<WorkResult, AwaError>

Claim and execute a single job, optionally filtered by queue.

pub async fn get_job(&self, job_id: i64) -> Result<JobRow, AwaError>

Get a job by ID.