diff --git a/crates/storage_models/src/query/generics.rs b/crates/storage_models/src/query/generics.rs index 2db2824603..bf09b2e594 100644 --- a/crates/storage_models/src/query/generics.rs +++ b/crates/storage_models/src/query/generics.rs @@ -24,7 +24,7 @@ use router_env::{instrument, logger, tracing}; use crate::{errors, PgPooledConn, StorageResult}; #[instrument(level = "DEBUG", skip_all)] -pub(super) async fn generic_insert(conn: &PgPooledConn, values: V) -> StorageResult +pub async fn generic_insert(conn: &PgPooledConn, values: V) -> StorageResult where T: HasTable + Table + 'static, V: Debug + Insertable, @@ -53,7 +53,7 @@ where } #[instrument(level = "DEBUG", skip_all)] -pub(super) async fn generic_update( +pub async fn generic_update( conn: &PgPooledConn, predicate: P, values: V, @@ -82,7 +82,7 @@ where } #[instrument(level = "DEBUG", skip_all)] -pub(super) async fn generic_update_with_results( +pub async fn generic_update_with_results( conn: &PgPooledConn, predicate: P, values: V, @@ -112,7 +112,7 @@ where } #[instrument(level = "DEBUG", skip_all)] -pub(super) async fn generic_update_by_id( +pub async fn generic_update_by_id( conn: &PgPooledConn, id: Pk, values: V, @@ -160,7 +160,7 @@ where } #[instrument(level = "DEBUG", skip_all)] -pub(super) async fn generic_delete(conn: &PgPooledConn, predicate: P) -> StorageResult +pub async fn generic_delete(conn: &PgPooledConn, predicate: P) -> StorageResult where T: FilterDsl

+ HasTable

+ Table + 'static, >::Output: IntoUpdateTarget, @@ -191,7 +191,7 @@ where } #[instrument(level = "DEBUG", skip_all)] -pub(super) async fn generic_delete_one_with_result( +pub async fn generic_delete_one_with_result( conn: &PgPooledConn, predicate: P, ) -> StorageResult @@ -247,7 +247,7 @@ where } #[instrument(level = "DEBUG", skip_all)] -pub(super) async fn generic_find_by_id(conn: &PgPooledConn, id: Pk) -> StorageResult +pub async fn generic_find_by_id(conn: &PgPooledConn, id: Pk) -> StorageResult where T: FindDsl + HasTable
+ LimitDsl + Table + 'static, >::Output: QueryFragment + RunQueryDsl + Send + 'static, @@ -260,7 +260,7 @@ where } #[instrument(level = "DEBUG", skip_all)] -pub(super) async fn generic_find_by_id_optional( +pub async fn generic_find_by_id_optional( conn: &PgPooledConn, id: Pk, ) -> StorageResult> @@ -302,7 +302,7 @@ where } #[instrument(level = "DEBUG", skip_all)] -pub(super) async fn generic_find_one(conn: &PgPooledConn, predicate: P) -> StorageResult +pub async fn generic_find_one(conn: &PgPooledConn, predicate: P) -> StorageResult where T: FilterDsl

+ HasTable

+ Table + 'static, >::Output: @@ -313,7 +313,7 @@ where } #[instrument(level = "DEBUG", skip_all)] -pub(super) async fn generic_find_one_optional( +pub async fn generic_find_one_optional( conn: &PgPooledConn, predicate: P, ) -> StorageResult> @@ -327,7 +327,7 @@ where } #[instrument(level = "DEBUG", skip_all)] -pub(super) async fn generic_filter( +pub async fn generic_filter( conn: &PgPooledConn, predicate: P, limit: Option,