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 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55
//! Tarantool async tokio based client. //! //! main features : auth by login and password, auto reconnect, optional timeout //! //! supported tarantool api : //! - call function //! - select //! - insert //! - replace //! - update //! - upsert //! - delete //! - eval //! //! # Examples //! //! ```text //! let mut rt = Runtime::new().unwrap(); //! //! let addr = "127.0.0.1:3301".parse().unwrap(); //! let client = ClientConfig::new(addr, "rust", "rust").set_timeout_time_ms(1000).build(); //! //! let response_future = client.call_fn2("test", &("param11", "param12") , &2) //! .and_then(|response| { //! let res : ((String,String), (u64,), (Option<u64>,)) = response.decode_trio()?; //! Ok(res) //! }) ; //! //! match rt.block_on(response_future) { //! Err(e) => println!("err={:?}", e), //! Ok(res) => println!("stored procedure response ={:?}", res) //! } //! ``` //! extern crate sha1; extern crate byteorder; extern crate bytes; extern crate futures; extern crate tokio; extern crate tokio_codec; extern crate maplit; extern crate rmpv; extern crate rmp_serde; extern crate serde; extern crate rmp; extern crate base64; #[macro_use] extern crate log; extern crate env_logger; pub mod tarantool;