diff --git a/packages/apalis-sql/src/mysql.rs b/packages/apalis-sql/src/mysql.rs index 7a2be32..b3ae469 100644 --- a/packages/apalis-sql/src/mysql.rs +++ b/packages/apalis-sql/src/mysql.rs @@ -114,6 +114,11 @@ impl MysqlStorage { pub fn codec(&self) -> &BoxCodec { &self.codec } + + /// Get the config used by the storage + pub fn get_config(&self) -> &Config { + &self.config + } } impl MysqlStorage { diff --git a/packages/apalis-sql/src/sqlite.rs b/packages/apalis-sql/src/sqlite.rs index 6a3e25d..751cbf0 100644 --- a/packages/apalis-sql/src/sqlite.rs +++ b/packages/apalis-sql/src/sqlite.rs @@ -149,6 +149,11 @@ impl SqliteStorage { pub fn codec(&self) -> &SqliteCodec { &self.codec } + + /// Get the config used by the storage + pub fn get_config(&self) -> &Config { + &self.config + } } async fn fetch_next(