diff --git a/Cargo.lock b/Cargo.lock index b5081a9c..9cde9e8c 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -653,7 +653,7 @@ dependencies = [ [[package]] name = "auction-server" -version = "0.32.1" +version = "0.32.2" dependencies = [ "anchor-lang", "anchor-lang-idl", diff --git a/auction-server/Cargo.toml b/auction-server/Cargo.toml index 806d1743..10a5ff2a 100644 --- a/auction-server/Cargo.toml +++ b/auction-server/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "auction-server" -version = "0.32.1" +version = "0.32.2" edition = "2021" license-file = "license.txt" diff --git a/auction-server/src/kernel/analytics_db.rs b/auction-server/src/kernel/analytics_db.rs index 799ca390..c5648075 100644 --- a/auction-server/src/kernel/analytics_db.rs +++ b/auction-server/src/kernel/analytics_db.rs @@ -10,10 +10,10 @@ pub struct ClickhouseInserter { pub sender: mpsc::Sender, } -const CHANNEL_SIZE: usize = 1000; +const CHANNEL_SIZE: usize = 10_000; const DURATION_PERIOD: Duration = Duration::from_secs(1); -const MAX_ROWS: u64 = 100; -const MAX_BYTES: u64 = 1_048_576; +const MAX_ROWS: u64 = 10_000; +const MAX_BYTES: u64 = 10 * 1_048_576; // 10 MB impl ClickhouseInserter { async fn run(client: clickhouse::Client, table_name: String, mut rx: mpsc::Receiver) {