Skip to content

Commit 539e5ed

Browse files
committed
chore: change streamingmode to exact for ranges with limits
1 parent e5b2d7f commit 539e5ed

File tree

6 files changed

+9
-9
lines changed

6 files changed

+9
-9
lines changed

engine/packages/epoxy/src/replica/messages/download_instances.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ pub async fn download_instances(
3939
let range = RangeOption {
4040
begin: begin_key,
4141
end: end_key,
42-
mode: StreamingMode::WantAll,
42+
mode: StreamingMode::Exact,
4343
limit: Some(req.count as usize),
4444
..Default::default()
4545
};

engine/packages/epoxy/src/workflows/replica/setup.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -443,10 +443,10 @@ pub async fn recover_keys_chunk(
443443

444444
// Scan for key instances
445445
let range_option = RangeOption {
446-
begin: begin_key,
447-
end: end_key,
446+
mode: StreamingMode::Exact,
448447
limit: Some(count as usize),
449-
mode: StreamingMode::WantAll,
448+
end: end_key,
449+
begin: begin_key,
450450
..Default::default()
451451
};
452452

engine/packages/gasoline/src/db/kv/debug.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -518,7 +518,7 @@ impl DatabaseDebug for DatabaseKv {
518518
async {
519519
tx.get_ranges_keyvalues(
520520
RangeOption {
521-
mode: StreamingMode::WantAll,
521+
mode: StreamingMode::Exact,
522522
limit: Some(1),
523523
..(&output_subspace).into()
524524
},
@@ -670,7 +670,7 @@ impl DatabaseDebug for DatabaseKv {
670670
async {
671671
tx.get_ranges_keyvalues(
672672
RangeOption {
673-
mode: StreamingMode::WantAll,
673+
mode: StreamingMode::Exact,
674674
limit: Some(1),
675675
..(&output_subspace).into()
676676
},

engine/packages/namespace/src/ops/runner_config/list.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,7 @@ pub async fn namespace_runner_config_list(
6464

6565
tx.get_ranges_keyvalues(
6666
universaldb::RangeOption {
67-
mode: StreamingMode::WantAll,
67+
mode: StreamingMode::Exact,
6868
limit: Some(input.limit),
6969
..(start, end).into()
7070
},

engine/packages/pegboard/src/ops/actor/list_names.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ pub async fn pegboard_actor_list_names(ctx: &OperationCtx, input: &Input) -> Res
4040

4141
tx.get_ranges_keyvalues(
4242
universaldb::RangeOption {
43-
mode: StreamingMode::WantAll,
43+
mode: StreamingMode::Exact,
4444
limit: Some(input.limit),
4545
..(start, end).into()
4646
},

engine/packages/pegboard/src/ops/runner/list_names.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ pub async fn pegboard_runner_list_names(ctx: &OperationCtx, input: &Input) -> Re
3939

4040
tx.get_ranges_keyvalues(
4141
universaldb::RangeOption {
42-
mode: StreamingMode::WantAll,
42+
mode: StreamingMode::Exact,
4343
limit: Some(input.limit),
4444
..(start, end).into()
4545
},

0 commit comments

Comments
 (0)