Skip to content

Commit 510deb5

Browse files
committed
Fix bench for simple push
ref #7
1 parent 35fd572 commit 510deb5

File tree

2 files changed

+27
-4
lines changed

2 files changed

+27
-4
lines changed

.travis.yml

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,7 @@ cache: cargo
66

77
rust:
88
- stable
9+
- nightly
910

1011
matrix:
1112
include:
@@ -25,6 +26,10 @@ matrix:
2526
env: TEST=1
2627
script:
2728
- cargo test
29+
- rust: nightly
30+
env: BENCH=1
31+
script:
32+
- cargo bench
2833
allow_failures:
2934
- rust: stable
3035
env: CLIPPY=1

benches/basic_basic.rs

Lines changed: 22 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,10 @@
11
#![feature(test)]
2-
extern crate sidekiq;
32
extern crate test;
3+
#[macro_use]
4+
extern crate serde_json;
5+
extern crate sidekiq;
46

7+
use serde_json::value::Value;
58
use sidekiq::{create_redis_pool, Client, ClientOpts, Job};
69
use test::Bencher;
710

@@ -11,16 +14,31 @@ fn get_client() -> Client {
1114
namespace: Some(ns.to_string()),
1215
..Default::default()
1316
};
14-
Client::new(create_redis_pool(), client_opts)
17+
let pool = create_redis_pool().unwrap();
18+
Client::new(pool, client_opts)
19+
}
20+
21+
fn args() -> Vec<Value> {
22+
let value = json!({
23+
"code": 200,
24+
"success": true,
25+
"payload": {
26+
"features": [
27+
"serde",
28+
"json"
29+
]
30+
}
31+
});
32+
let args: Vec<Value> = vec![value];
33+
args
1534
}
1635

1736
#[bench]
1837
fn bench_simple_push(b: &mut Bencher) {
1938
let client = get_client();
2039
b.iter(|| {
2140
let class = "Test".to_string();
22-
let args = "[\"arg1\",\"arg2\"]".to_string();
23-
let job = Job::new(class, args, Default::default());
41+
let job = Job::new(class, args(), Default::default());
2442
client.push(job)
2543
});
2644
}

0 commit comments

Comments
 (0)