Struct PgListen

pub struct PgListen { /* private fields */ }

Available on crate feature postgres only.

A listener that listens to Postgres notifications

Implementations

impl PgListen

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

Build a new listener.

Maintaining a connection can be expensive, its encouraged you only create one PgListen and share it with multiple PostgresStorage

pub fn subscribe_with<T>(&mut self, storage: &mut PostgresStorage<T>)

Add a new subscription with a storage

pub fn subscribe(&mut self, namespace: &str) -> PgSubscription

Add a new subscription

pub async fn listen(self) -> Result<(), Error>

Start listening to jobs

Trait Implementations

impl Debug for PgListen

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

Formats the value using the given formatter.