daqbuf/daqbuffer
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Limit connection count

Browse Source
This commit is contained in:
Dominik Werder
2025-05-16 14:53:28 +02:00
parent b9434b9942
commit 24fc2d888f
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
crates/scyllaconn/src/conn.rs
View File

@@ -1,10 +1,11 @@
use netpod::log::*;
use netpod::ScyllaConfig;
use netpod::log::*;
use scylla::client::execution_profile::ExecutionProfileBuilder;
use scylla::client::session::Session;
use scylla::client::session_builder::SessionBuilder;
use scylla::errors::NewSessionError;
use scylla::statement::Consistency;
use std::num::NonZero;
use std::sync::Arc;
autoerr::create_error_v1!(
@@ -25,6 +26,7 @@ pub async fn create_scy_session(scyconf: &ScyllaConfig) -> Result<Arc<Session>,
pub async fn create_scy_session_no_ks(scyconf: &ScyllaConfig) -> Result<Session, Error> {
info!("creating scylla connection");
let scy = SessionBuilder::new()
.pool_size(scylla::client::PoolSize::PerHost(NonZero::new(4).unwrap()))
.known_nodes(&scyconf.hosts)
.default_execution_profile_handle(
ExecutionProfileBuilder::default()