Struct PgQueueWorkerRepository

pub struct PgQueueWorkerRepository<'c> { /* private fields */ }

An implementation of [QueueWorkerRepository] for a PostgreSQL connection.

Implementations

impl<'c> PgQueueWorkerRepository<'c>

pub fn new(conn: &'c mut PgConnection) -> Self

Create a new PgQueueWorkerRepository from an active PostgreSQL connection.

Trait Implementations

impl QueueWorkerRepository for PgQueueWorkerRepository<'_>

type Error = DatabaseError

The error type returned by the repository.

fn register<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, rng: &'life1 mut (dyn RngCore + Send), clock: &'life2 dyn Clock, ) -> Pin<Box<dyn Future<Output = Result<Worker, Self::Error>> + Send + 'async_trait>>

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

Register a new worker.

fn heartbeat<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, clock: &'life1 dyn Clock, worker: &'life2 Worker, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

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

Send a heartbeat for the given worker.

fn shutdown<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, clock: &'life1 dyn Clock, worker: &'life2 Worker, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

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

Mark the given worker as shutdown.

fn shutdown_dead_workers<'life0, 'life1, 'async_trait>( &'life0 mut self, clock: &'life1 dyn Clock, threshold: Duration, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

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

Find dead workers and shut them down.

fn remove_leader_lease_if_expired<'life0, 'life1, 'async_trait>( &'life0 mut self, _clock: &'life1 dyn Clock, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

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

Remove the leader lease if it is expired, sending a notification to trigger a new leader election.

fn try_get_leader_lease<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, clock: &'life1 dyn Clock, worker: &'life2 Worker, ) -> Pin<Box<dyn Future<Output = Result<bool, Self::Error>> + Send + 'async_trait>>

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

Try to get the leader lease, renewing it if we already have it