Struct WorkerUtilsWithExecutor 

pub struct WorkerUtilsWithExecutor<E> { /* private fields */ }

A scoped WorkerUtils facade that routes operations through a caller-provided executor.

Use WorkerUtils::with_executor when job operations must participate in an existing transaction. The caller owns the executor lifecycle and remains responsible for committing or rolling back transactions.

Maintenance operations that manage their own transaction or shared state (cleanup, migrate, and stale-worker sweeps) remain available only on WorkerUtils.

Implementations

impl<E> WorkerUtilsWithExecutor<E>

where E: DbExecutorArg,

pub fn into_inner(self) -> WorkerUtils

Returns the configured WorkerUtils, releasing the injected executor.

pub async fn add_job<T>( &mut self, payload: T, spec: JobSpec, ) -> Result<Job, GraphileWorkerError>

where T: TaskHandler,

Adds a job to the queue with type safety.

pub async fn add_raw_job<P>( &mut self, identifier: &str, payload: P, spec: JobSpec, ) -> Result<Job, GraphileWorkerError>

where P: Serialize,

Adds a job to the queue with a raw identifier and payload.

pub async fn add_jobs<T>( &mut self, jobs: &[(T, &JobSpec)], ) -> Result<Vec<Job>, GraphileWorkerError>

where T: TaskHandler + Clone,

Adds multiple jobs of the same type in one database operation.

pub async fn add_raw_jobs( &mut self, jobs: &[RawJobSpec], ) -> Result<Vec<Job>, GraphileWorkerError>

Adds multiple jobs with raw identifiers and payloads in one database operation.

pub async fn add_batch_job<T>( &mut self, payloads: Vec<T>, spec: JobSpec, ) -> Result<Job, GraphileWorkerError>

where T: BatchTaskHandler,

Adds a batch job to the queue with type safety.

pub async fn remove_job( &mut self, job_key: &str, ) -> Result<(), GraphileWorkerError>

Removes a job from the queue by its job key.

pub async fn complete_jobs( &mut self, ids: &[i64], ) -> Result<Vec<DbJob>, GraphileWorkerError>

Marks multiple jobs as completed.

pub async fn permanently_fail_jobs( &mut self, ids: &[i64], reason: &str, ) -> Result<Vec<DbJob>, GraphileWorkerError>

Marks multiple jobs as permanently failed with a reason.

pub async fn reschedule_jobs( &mut self, ids: &[i64], options: RescheduleJobOptions, ) -> Result<Vec<DbJob>, GraphileWorkerError>

Reschedules multiple jobs with new parameters.

pub async fn list_active_workers( &mut self, sweep_threshold: Duration, ) -> Result<Vec<ActiveWorkerRow>, GraphileWorkerError>

Lists workers registered in the heartbeat table.

pub async fn force_unlock_workers( &mut self, worker_ids: &[&str], ) -> Result<(), GraphileWorkerError>

Force unlocks worker records in the database.