Struct PostgresDatastore 

pub struct PostgresDatastore { /* private fields */ }

PostgreSQL implementation of the datastore

Implementations

impl PostgresDatastore

pub async fn new(pool: Pool<Postgres>) -> JobResult<Self>

Create a new PostgreSQL datastore

pub async fn migrate(&self) -> JobResult<()>

Run database migrations

pub fn pool(&self) -> &PgPool

Get a reference to the connection pool

Trait Implementations

impl Clone for PostgresDatastore

fn clone(&self) -> PostgresDatastore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Datastore for PostgresDatastore

fn insert_job<'life0, 'async_trait>( &'life0 self, record: Job, ) -> Pin<Box<dyn Future<Output = JobResult<Uuid>> + Send + 'async_trait>>

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

Insert a new job

fn get_job<'life0, 'async_trait>( &'life0 self, job_id: Uuid, ) -> Pin<Box<dyn Future<Output = JobResult<Option<Job>>> + Send + 'async_trait>>

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

Get a job by ID

fn get_all_jobs<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = JobResult<Vec<Job>>> + Send + 'async_trait>>

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

Get all jobs

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

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

Update a job

fn delete_job<'life0, 'async_trait>( &'life0 self, job_id: Uuid, ) -> Pin<Box<dyn Future<Output = JobResult<()>> + Send + 'async_trait>>

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

Delete a job

fn claim_next_job<'life0, 'async_trait>( &'life0 self, locked_until: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = JobResult<Option<Job>>> + Send + 'async_trait>>

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

Atomically claim the next available job