From 11e1a51a2a2e571d0e51e11f380626f3e4f57cbe Mon Sep 17 00:00:00 2001 From: Tobias Reisinger Date: Fri, 10 May 2024 18:03:02 +0200 Subject: [PATCH] Add parameter for db pool size --- Cargo.lock | Bin 70492 -> 70393 bytes src/main.rs | 4 +++- 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/Cargo.lock b/Cargo.lock index 25b09ed803e02194876bb4959a4b9cf83a49374e..9ca1b7e64c13bdd8c548a552938fbf8dd7b41efe 100644 GIT binary patch delta 18 acmcb!jOFK2mJL--lSTZ6H-B)-xc~rE#t6Rv delta 109 zcmeyll;zGcmJL--ll?Nd!qPKKv@=Rd3W}}t^?_`?;?$z_(yGi{z1&p&)ZFyM((*+8 z;n diff --git a/src/main.rs b/src/main.rs index 003633f..d37a39c 100644 --- a/src/main.rs +++ b/src/main.rs @@ -27,7 +27,8 @@ async fn main() -> Result<(), std::io::Error> { init_logging(&settings.logging.level)?; - let pool = emgauwa_common::db::init(&settings.database).await?; + let pool_size = 10; + let pool = emgauwa_common::db::init(&settings.database, pool_size).await?; let mut conn = pool.acquire().await.map_err(EmgauwaError::from)?; DbController::all_inactive(&mut conn) @@ -112,6 +113,7 @@ async fn main() -> Result<(), std::io::Error> { .service(handlers::v1::ws::ws_relays), ) }) + .workers((pool_size / 2) as usize) .listen(listener)? .run() .await