From 8ded66c4cfe8c663f0ba676ae3c43e4300a7756e Mon Sep 17 00:00:00 2001 From: Tsiry Sandratraina Date: Sun, 11 Jan 2026 15:58:40 +0300 Subject: [PATCH] update connection pool options --- crates/jetstream/src/subscriber.rs | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/crates/jetstream/src/subscriber.rs b/crates/jetstream/src/subscriber.rs index 5a965711..86deb9db 100644 --- a/crates/jetstream/src/subscriber.rs +++ b/crates/jetstream/src/subscriber.rs @@ -1,4 +1,4 @@ -use std::{env, sync::Arc}; +use std::{env, sync::Arc, time::Duration}; use anyhow::{Context, Error}; use futures_util::StreamExt; @@ -36,6 +36,11 @@ impl ScrobbleSubscriber { let pool = PgPoolOptions::new() .max_connections(5) + .min_connections(2) + .acquire_timeout(Duration::from_secs(12)) + .idle_timeout(Some(Duration::from_secs(10 * 60))) + .max_lifetime(Some(Duration::from_secs(60 * 14))) + .test_before_acquire(true) .connect(&db_url) .await?; let pool = Arc::new(Mutex::new(pool)); -- 2.51.2