Struct JobRepository 

pub struct JobRepository { /* private fields */ }

PostgreSQL implementation of the job queue.

Uses SELECT FOR UPDATE SKIP LOCKED for safe concurrent job claiming, ensuring that multiple workers can process jobs without conflicts.

Implementations

impl JobRepository

pub fn new(pool: PgPool) -> Self

Create a new job repository with the given connection pool.

Trait Implementations

impl Clone for JobRepository

fn clone(&self) -> JobRepository

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl JobQueue for JobRepository

async fn create_job( &self, request: CreateJobRequest, ) -> Result<HarvestJob, AppError>

Create a new job in the queue.

async fn claim_job( &self, worker_id: &str, ) -> Result<Option<HarvestJob>, AppError>

Claim the next available pending job for processing.

async fn complete_job( &self, job_id: Uuid, stats: SyncStats, ) -> Result<(), AppError>

Mark a job as completed with final statistics.

async fn fail_job( &self, job_id: Uuid, error: &str, next_retry_at: Option<DateTime<Utc>>, ) -> Result<(), AppError>

Mark a job as failed with error message.

async fn cancel_job( &self, job_id: Uuid, stats: Option<SyncStats>, ) -> Result<(), AppError>

Mark a job as cancelled.

async fn get_job(&self, job_id: Uuid) -> Result<Option<HarvestJob>, AppError>

Get a job by ID.

async fn list_jobs( &self, status: Option<JobStatus>, limit: usize, ) -> Result<Vec<HarvestJob>, AppError>

List jobs with optional status filter.

async fn release_job(&self, job_id: Uuid) -> Result<(), AppError>

Release a job back to pending state.

async fn release_worker_jobs(&self, worker_id: &str) -> Result<u64, AppError>

Release all jobs claimed by a specific worker.

async fn count_by_status(&self, status: JobStatus) -> Result<i64, AppError>

Get count of jobs by status.