forked from
rocksky.app/rocksky
A decentralized music tracking and discovery platform built on AT Protocol 🎵
feat: configure connection pool with idle timeout and max size for DuckdbRepo
+4
-1
+4
-1
crates/feed/src/repo/duckdb/mod.rs
+4
-1
crates/feed/src/repo/duckdb/mod.rs
···
27
27
impl DuckdbRepo {
28
28
pub async fn new() -> Result<Self, Error> {
29
29
let manager = DuckDBConnectionManager::file(DB_PATH);
30
-
let pool = r2d2::Pool::builder().build(manager)?;
30
+
let pool = r2d2::Pool::builder()
31
+
.idle_timeout(Some(std::time::Duration::from_secs(60)))
32
+
.max_size(15)
33
+
.build(manager)?;
31
34
Ok(Self { pool })
32
35
}
33
36
}