kramer 3.0.0

Enumerated types implementing std::fmt::Display for sending RESP messages to redis.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

#![cfg(not(feature = "kramer-async"))]
#![feature(test)]

extern crate test;

use kramer::{execute, Arity, Command, Insertion, StringCommand};
use std::env::var;
use test::Bencher;

fn get_redis_url() -> String {
  let host = var("REDIS_HOST").unwrap_or(String::from("0.0.0.0"));
  let port = var("REDIS_PORT").unwrap_or(String::from("6379"));
  format!("{}:{}", host, port)
}

#[bench]
fn bench_kramer_set_del_sync(b: &mut Bencher) {
  b.iter(|| {
    let key = "kramer_async";
    let mut stream = std::net::TcpStream::connect(get_redis_url()).expect("connected");
    let set_cmd = StringCommand::Set(Arity::One((key, "42")), None, Insertion::Always);
    execute(&mut stream, set_cmd).expect("written");
    let del_cmd = Command::Del::<_, &str>(Arity::One(key));
    execute(&mut stream, del_cmd).expect("written");
    Ok::<(), std::io::Error>(())
  });
}