Skip to content

Commit 0ff80b6

Browse files
committed
feat: add option to skip queries in benchmark
1 parent 8ee4c02 commit 0ff80b6

4 files changed

Lines changed: 18 additions & 0 deletions

File tree

src/bench_utils.rs

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,9 @@ pub struct Args {
2626

2727
#[arg(long, num_args = 0..=1, default_missing_value = "profile.pb")]
2828
pub profile: Option<String>,
29+
30+
#[arg(long, default_value_t = false)]
31+
pub skip_queries: bool,
2932
}
3033

3134
#[derive(Clone)]

src/bin/bench_runner.rs

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -85,6 +85,11 @@ async fn main() {
8585
return;
8686
}
8787

88+
if args.skip_queries {
89+
println!("Skipping queries...");
90+
return;
91+
}
92+
8893
// 3. Load Queries
8994
let queries = Arc::new(load_queries());
9095
if queries.is_empty() {

src/bin/bench_runner_mongo.rs

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -79,6 +79,11 @@ async fn main() {
7979
return;
8080
}
8181

82+
if args.skip_queries {
83+
println!("Skipping queries...");
84+
return;
85+
}
86+
8287
let queries = Arc::new(load_queries());
8388
let ctx = Arc::new(db);
8489

src/bin/bench_runner_server.rs

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -161,6 +161,11 @@ async fn main() {
161161
return;
162162
}
163163

164+
if args.skip_queries {
165+
println!("Skipping queries...");
166+
return;
167+
}
168+
164169
// 4. Establish connections for benchmark
165170
let mut clients = Vec::new();
166171
let mut _handles = Vec::new();

0 commit comments

Comments
 (0)