Struct PostgresStorageFactory 

pub struct PostgresStorageFactory { /* private fields */ }

A factory for creating PostgreSQL-backed task queues.

PostgresStorageFactory maintains a shared PostgreSQL LISTEN connection and routes job insertion notifications to the corresponding queue.

Each queue created by the factory is identified by its queue name. Multiple backends can therefore share a single notification listener while retaining independent task polling and processing.

Example

use apalis_core::backend::factory::BackendFactory;
use apalis_postgres::factory::PostgresStorageFactory;
use sqlx::PgPool;

let pool = PgPool::connect("postgres://localhost/apalis").await?;
let mut factory = PostgresStorageFactory::new(pool);

let backend = factory.create::<u64>()?;

Implementations

impl PostgresStorageFactory

pub fn new(pool: PgPool) -> Self

Creates a new factory backed by the given PostgreSQL connection pool.

A single PostgreSQL notification listener is shared by all backends created by this factory.

Trait Implementations

impl<Args> BackendFactory<Args> for PostgresStorageFactory

type Backend = PollWith<PostgresStorage<Args>, StreamStrategy<SharedFetcher>>

The backend type produced by this factory.

type Error = PostgresFactoryError

The error returned if backend creation fails.

fn create(&mut self) -> Result<Self::Backend, Self::Error>

where <Self::Backend as BackendConfig>::Config: Default,

Create a backend using Config::default().

fn create_with_config( &mut self, config: Config, ) -> Result<Self::Backend, Self::Error>

Create a backend using the given configuration.