redis_with_ns.rs

extern crate env_logger;
extern crate futures;
extern crate abstract_ns;
extern crate tokio_core;
extern crate tokio_redis as redis;
extern crate ns_dns_tokio;

use std::error::Error;

use abstract_ns::Resolver;
use futures::Future;
use tokio_core::reactor::Core;
use redis::Client;
use ns_dns_tokio::DnsResolver;

pub fn main() {
    env_logger::init().unwrap();

    let mut lp = Core::new().unwrap();
    let resolver = DnsResolver::system_config(&lp.handle())
        .expect("initialize DNS resolver");
    let handle = lp.handle();
    let fut = resolver.resolve("localhost:6379")
    .map_err(|e| Box::new(e) as Box<Error>)
    .and_then(|addresses| {
        let client = Client::new().connect(&handle,
                                           &addresses.pick_one().unwrap());

        let r1 = client.set("zomghi2u", "SOME VALUE");
        r1.and_then(move |_| client.get("zomghi2u"))
        .map_err(|e| Box::new(e) as Box<Error>)
    });
    let val = lp.run(fut).unwrap();

    println!("RESPONSE: {:?}", val);
}