Struct PgMiddleware 

pub struct PgMiddleware { /* private fields */ }

Middleware layer used by the PostgreSQL backend.

The lock step always runs. The acknowledge step is installed only when the queue config has automatic acknowledgement enabled.

Implementations

impl PgMiddleware

pub fn new(pool: PgPool, auto_ack: bool) -> Self

Create the PostgreSQL backend middleware.

pub fn with_lease_token( pool: PgPool, auto_ack: bool, lease_token: Arc<str>, ) -> Self

Create the PostgreSQL backend middleware with lease-token binding for the auto-ack path. Used by crate::PostgresStorage so completed jobs can only be acknowledged by a worker possessing the per-storage token.

pub fn auto_ack(&self) -> bool

Return whether this middleware will acknowledge tasks after execution.

Trait Implementations

impl Clone for PgMiddleware

fn clone(&self) -> PgMiddleware

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PgMiddleware

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

Formats the value using the given formatter.

impl<S> Layer<S> for PgMiddleware

where AcknowledgeLayer<PgAck>: Layer<LockTaskService<S>>,

type Service = PgMiddlewareService<<AcknowledgeLayer<PgAck> as Layer<LockTaskService<S>>>::Service, LockTaskService<S>>

The wrapped service

fn layer(&self, inner: S) -> Self::Service

Wrap the given service with the middleware, returning a new service that has been decorated with the middleware.