Struct PostgresBackend 

pub struct PostgresBackend { /* private fields */ }

Implementations

impl PostgresBackend

pub async fn new(pool: Pool) -> Result<Self, Error>

Create and initialize a new Postgres backend with the given connection pool.

Trait Implementations

impl Backend for PostgresBackend

type Error = Error

The error type for backend operations.

async fn add_job_types(&self, job_types: &[JobType]) -> Result<(), Error>

Add or update job types.

async fn list_job_types(&self) -> Result<Vec<JobType>, Error>

List all job types.

async fn add_jobs( &self, jobs: &[NewJob], if_not_exists: Option<JobFilters>, ) -> Result<Vec<JobId>, Error>

Add new jobs and return their IDs in the same order.

async fn list_jobs( &self, filters: JobFilters, order_by: Option<JobOrderBy>, page_size: u32, page_token: Option<NextPageToken>, ) -> Result<(Vec<JobDetails>, Option<NextPageToken>), Error>

List jobs matching the given filters.

async fn count_jobs(&self, filters: JobFilters) -> Result<u64, Error>

Count the jobs matching the given filters.

async fn cancel_jobs( &self, filters: JobFilters, ) -> Result<Vec<CancelledJob>, Error>

Cancel the jobs matching the given filters, returning the cancelled jobs.

async fn add_schedules( &self, schedules: &[ScheduleDefinition], if_not_exists: Option<ScheduleFilters>, ) -> Result<Vec<ScheduleId>, Error>

Add new schedules and return their IDs in the same order.

async fn list_schedules( &self, filters: ScheduleFilters, order_by: Option<ScheduleOrderBy>, page_size: u32, page_token: Option<NextPageToken>, ) -> Result<(Vec<ScheduleDetails>, Option<NextPageToken>), Error>

List schedules matching the given filters.

async fn count_schedules(&self, filters: ScheduleFilters) -> Result<u64, Error>

Count the schedules matching the given filters.

async fn stop_schedules( &self, filters: ScheduleFilters, ) -> Result<Vec<StoppedSchedule>, Error>

Stop the schedules matching the given filters, returning the IDs of the stopped schedules.

fn ready_executions( &self, ) -> impl Stream<Item = Result<Vec<ReadyExecution>, Error>> + Send

Return ready executions.

async fn wait_for_ready_executions(&self) -> Result<(), Error>

Wait for executions to be ready.

fn in_progress_executions( &self, ) -> impl Stream<Item = Result<Vec<InProgressExecution>, Error>> + Send

Return a stream of in-progress executions.

async fn executions_started( &self, executions: &[StartedExecution], ) -> Result<(), Error>

The given executions have started.

async fn executions_succeeded( &self, executions: &[SucceededExecution], ) -> Result<(), Error>

The given executions have successfully completed.

async fn executions_failed( &self, executions: &[FailedExecution], ) -> Result<(), Error>

The given executions have failed.

async fn executions_retried( &self, executions: &[FailedExecution], ) -> Result<(), Error>

The given executions have failed but need to be retried.

fn pending_schedules( &self, ) -> impl Stream<Item = Result<Vec<PendingSchedule>, Error>> + Send

Return a stream of active schedules that do not have an active job.

async fn delete_history(&self, before: SystemTime) -> Result<(), Error>

Delete historical data for inactive jobs and schedules.

async fn wait_for_pending_schedules(&self) -> Result<(), Error>

Wait for pending schedules to be available.