Struct RexecutorPgBackend

pub struct RexecutorPgBackend { /* private fields */ }

A postgres implementation of a rexecutor::backend::Backend.

Implementations

impl RexecutorPgBackend

pub async fn from_db_url(db_url: &str) -> Result<Self, BackendError>

Creates a new RexecutorPgBackend from a db connection string.

pub async fn from_pool(pool: PgPool) -> Result<Self, BackendError>

Create a new RexecutorPgBackend from an existing PgPool.

pub async fn run_migrations(&self) -> Result<(), BackendError>

This can be used to run the RexecutorPgBackend’s migrations.

Trait Implementations

impl Backend for RexecutorPgBackend

fn subscribe_ready_jobs<'life0, 'async_trait>( &'life0 self, executor_identifier: ExecutorIdentifier, ) -> Pin<Box<dyn Future<Output = Pin<Box<dyn Stream<Item = Result<Job, BackendError>> + Send>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns a stream of the jobs ready to be executed.

fn enqueue<'a, 'life0, 'async_trait>( &'life0 self, job: EnqueuableJob<'a>, ) -> Pin<Box<dyn Future<Output = Result<JobId, BackendError>> + Send + 'async_trait>>

where Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait,

Enqueue a job to the backend.

fn mark_job_complete<'life0, 'async_trait>( &'life0 self, id: JobId, ) -> Pin<Box<dyn Future<Output = Result<(), BackendError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Mark a job as having been completed.

fn mark_job_retryable<'life0, 'async_trait>( &'life0 self, id: JobId, next_scheduled_at: DateTime<Utc>, error: ExecutionError, ) -> Pin<Box<dyn Future<Output = Result<(), BackendError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Mark a job as retryable and schedule to run it again at the given instance.

fn mark_job_discarded<'life0, 'async_trait>( &'life0 self, id: JobId, error: ExecutionError, ) -> Pin<Box<dyn Future<Output = Result<(), BackendError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Mark a job as discarded (this is the state where the job has failed to complete successfully after reaching its max_attempts.

fn mark_job_cancelled<'life0, 'async_trait>( &'life0 self, id: JobId, error: ExecutionError, ) -> Pin<Box<dyn Future<Output = Result<(), BackendError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Mark a job as cancelled.

fn mark_job_snoozed<'life0, 'async_trait>( &'life0 self, id: JobId, next_scheduled_at: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<(), BackendError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Mark a job as snoozed.

fn prune_jobs<'life0, 'life1, 'async_trait>( &'life0 self, spec: &'life1 PruneSpec, ) -> Pin<Box<dyn Future<Output = Result<(), BackendError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Remove the jobs according to the provided PruneSpec.

fn rerun_job<'life0, 'async_trait>( &'life0 self, id: JobId, ) -> Pin<Box<dyn Future<Output = Result<(), BackendError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Rerun the given job.

fn update_job<'life0, 'async_trait>( &'life0 self, job: Job, ) -> Pin<Box<dyn Future<Output = Result<(), BackendError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Update the job with the updated details in the Job.

fn query<'a, 'life0, 'async_trait>( &'life0 self, query: Query<'a>, ) -> Pin<Box<dyn Future<Output = Result<Vec<Job>, BackendError>> + Send + 'async_trait>>

where Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait,

Query for jobs according to the specification in the Query.

impl Clone for RexecutorPgBackend

fn clone(&self) -> RexecutorPgBackend

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for RexecutorPgBackend

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.