CDRS session

main.rs

use cdrs::client::{CDRS, Credentials, Session};
use cdrs::{error as cdrs_error};
use cdrs::authenticators::{Authenticator, PasswordAuthenticator};
use cdrs::compression::Compression;

fn main() {
  let addr = "127.0.0.1:9042";
  let authenticator = PasswordAuthenticator::new("user", "password");
  let mut session = new_session(addr, authenticator).unwrap();
  
  // ... work with session
  
  session.end();
}

// Creates new session with server of addres `addr` using provided authenticator
fn new_session<A: Authenticator>(addr: &str, authenticator: A) -> cdrs_error::Result<Session<A>> {
  let cdrs = CDRS::new(addr, authenticator);
  // establish session without compression so far
  return cdrs.start(Compression::None);
}