From 84dbac3861a342c37b3e63e1503fba216bfa6d23 Mon Sep 17 00:00:00 2001 From: Alexander Tesfamichael Date: Sun, 5 Nov 2023 11:19:09 +0100 Subject: [PATCH] feat(migrate-from-gcs): reduce buffer sizes --- src/bin/migrate-from-gcs/main.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/bin/migrate-from-gcs/main.rs b/src/bin/migrate-from-gcs/main.rs index a28878a..f534159 100644 --- a/src/bin/migrate-from-gcs/main.rs +++ b/src/bin/migrate-from-gcs/main.rs @@ -274,10 +274,10 @@ async fn main() -> anyhow::Result<()> { let payload_day_stream = gcs.get(&object_meta.location).await?.into_stream(); - const DECODED_BUFFER_SIZE: usize = 256; + const DECODED_BUFFER_SIZE: usize = 128; let (payload_tx, payload_rx) = channel(DECODED_BUFFER_SIZE); - const SLOT_BUNDLE_BUFFER_SIZE: usize = 8; + const SLOT_BUNDLE_BUFFER_SIZE: usize = 6; let (slot_bundle_tx, slot_bundle_rx) = channel(SLOT_BUNDLE_BUFFER_SIZE); try_join!(