From cd862c4209a398bfc52d4813e601311bba3eb8b8 Mon Sep 17 00:00:00 2001 From: MasterPtato Date: Mon, 17 Nov 2025 13:08:34 -0800 Subject: [PATCH] chore: change streamingmode to exact for ranges with limits --- .../epoxy/src/replica/messages/download_instances.rs | 2 +- engine/packages/epoxy/src/workflows/replica/setup.rs | 6 +++--- engine/packages/gasoline/src/db/kv/debug.rs | 4 ++-- engine/packages/namespace/src/ops/runner_config/list.rs | 2 +- engine/packages/pegboard/src/ops/actor/list_names.rs | 2 +- engine/packages/pegboard/src/ops/runner/list_names.rs | 2 +- 6 files changed, 9 insertions(+), 9 deletions(-) diff --git a/engine/packages/epoxy/src/replica/messages/download_instances.rs b/engine/packages/epoxy/src/replica/messages/download_instances.rs index 7942a61252..122ce2d0ee 100644 --- a/engine/packages/epoxy/src/replica/messages/download_instances.rs +++ b/engine/packages/epoxy/src/replica/messages/download_instances.rs @@ -39,7 +39,7 @@ pub async fn download_instances( let range = RangeOption { begin: begin_key, end: end_key, - mode: StreamingMode::WantAll, + mode: StreamingMode::Exact, limit: Some(req.count as usize), ..Default::default() }; diff --git a/engine/packages/epoxy/src/workflows/replica/setup.rs b/engine/packages/epoxy/src/workflows/replica/setup.rs index c85993e6d5..b699366144 100644 --- a/engine/packages/epoxy/src/workflows/replica/setup.rs +++ b/engine/packages/epoxy/src/workflows/replica/setup.rs @@ -443,10 +443,10 @@ pub async fn recover_keys_chunk( // Scan for key instances let range_option = RangeOption { - begin: begin_key, - end: end_key, + mode: StreamingMode::Exact, limit: Some(count as usize), - mode: StreamingMode::WantAll, + end: end_key, + begin: begin_key, ..Default::default() }; diff --git a/engine/packages/gasoline/src/db/kv/debug.rs b/engine/packages/gasoline/src/db/kv/debug.rs index a2e0b68420..624220077a 100644 --- a/engine/packages/gasoline/src/db/kv/debug.rs +++ b/engine/packages/gasoline/src/db/kv/debug.rs @@ -518,7 +518,7 @@ impl DatabaseDebug for DatabaseKv { async { tx.get_ranges_keyvalues( RangeOption { - mode: StreamingMode::WantAll, + mode: StreamingMode::Exact, limit: Some(1), ..(&output_subspace).into() }, @@ -670,7 +670,7 @@ impl DatabaseDebug for DatabaseKv { async { tx.get_ranges_keyvalues( RangeOption { - mode: StreamingMode::WantAll, + mode: StreamingMode::Exact, limit: Some(1), ..(&output_subspace).into() }, diff --git a/engine/packages/namespace/src/ops/runner_config/list.rs b/engine/packages/namespace/src/ops/runner_config/list.rs index c0fcf8de95..5e517b12c0 100644 --- a/engine/packages/namespace/src/ops/runner_config/list.rs +++ b/engine/packages/namespace/src/ops/runner_config/list.rs @@ -64,7 +64,7 @@ pub async fn namespace_runner_config_list( tx.get_ranges_keyvalues( universaldb::RangeOption { - mode: StreamingMode::WantAll, + mode: StreamingMode::Exact, limit: Some(input.limit), ..(start, end).into() }, diff --git a/engine/packages/pegboard/src/ops/actor/list_names.rs b/engine/packages/pegboard/src/ops/actor/list_names.rs index ac15a99f6c..0267dd8246 100644 --- a/engine/packages/pegboard/src/ops/actor/list_names.rs +++ b/engine/packages/pegboard/src/ops/actor/list_names.rs @@ -40,7 +40,7 @@ pub async fn pegboard_actor_list_names(ctx: &OperationCtx, input: &Input) -> Res tx.get_ranges_keyvalues( universaldb::RangeOption { - mode: StreamingMode::WantAll, + mode: StreamingMode::Exact, limit: Some(input.limit), ..(start, end).into() }, diff --git a/engine/packages/pegboard/src/ops/runner/list_names.rs b/engine/packages/pegboard/src/ops/runner/list_names.rs index 518971521e..0349b7ca8b 100644 --- a/engine/packages/pegboard/src/ops/runner/list_names.rs +++ b/engine/packages/pegboard/src/ops/runner/list_names.rs @@ -39,7 +39,7 @@ pub async fn pegboard_runner_list_names(ctx: &OperationCtx, input: &Input) -> Re tx.get_ranges_keyvalues( universaldb::RangeOption { - mode: StreamingMode::WantAll, + mode: StreamingMode::Exact, limit: Some(input.limit), ..(start, end).into() },