apalis_postgres/
config.rs

1use apalis_core::backend::{Backend, ConfigExt, queue::Queue};
2use apalis_sql::context::SqlContext;
3use ulid::Ulid;
4
5pub use apalis_sql::config::*;
6
7use crate::{CompactType, PostgresStorage};
8
9impl<Args: Sync, D, F> ConfigExt for PostgresStorage<Args, CompactType, D, F>
10where
11    PostgresStorage<Args, CompactType, D, F>:
12        Backend<Context = SqlContext, Compact = CompactType, IdType = Ulid, Error = sqlx::Error>,
13{
14    fn get_queue(&self) -> Queue {
15        self.config.queue().clone()
16    }
17}