Struct cdrs::cluster::Session

pub struct Session<LB, A> {
    pub compression: Compression,
    // some fields omitted
}

Fields

compression: Compression

Methods

impl<'a, LB: Sized, A: Authenticator + 'a + Sized> Session<LB, A>

pub fn paged<T: CDRSTransport>(     &'a mut self,     page_size: i32 ) -> SessionPager<'a, Session<LB, A>, T> where     Session<LB, A>: CDRSSession<'a, T>,

impl<'a, LB: LoadBalancingStrategy<TransportTcp> + Sized, A: Authenticator + 'a + Sized> Session<LB, A>

pub fn new(     addrs: &Vec<&str>,     load_balancing: LB,     authenticator: A ) -> Result<Session<LB, A>>

pub fn new_snappy(     addrs: &Vec<&str>,     load_balancing: LB,     authenticator: A ) -> Result<Session<LB, A>>

pub fn new_lz4(     addrs: &Vec<&str>,     load_balancing: LB,     authenticator: A ) -> Result<Session<LB, A>>

pub fn listen(     &mut self,     events: Vec<SimpleServerEvent> ) -> Result<(Listener<TransportTcp>, EventStream)>

Trait Implementations

impl<'a, LB, A> GetCompressor<'a> for Session<LB, A>

fn get_compressor(&self) -> Compression

impl<'a, T: CDRSTransport + 'a, LB: LoadBalancingStrategy<T> + Sized, A: Authenticator + Sized> GetTransport<'a, T> for Session<LB, A>

fn get_transport(&mut self) -> Option<&mut T>

impl<'a, T: CDRSTransport + 'a, LB: LoadBalancingStrategy<T> + Sized, A: Authenticator + Sized> QueryExecutor<'a, T> for Session<LB, A>

fn query_with_params_tw<Q: ToString>(     &mut self,     query: Q,     query_params: QueryParams,     with_tracing: bool,     with_warnings: bool ) -> Result<Frame>

fn query<Q: ToString>(&mut self, query: Q) -> Result<Frame>

Executes a query with default parameters: * TDB

fn query_tw<Q: ToString>(     &mut self,     query: Q,     with_tracing: bool,     with_warnings: bool ) -> Result<Frame>

Executes a query with ability to trace it and see warnings, and default parameters: * TBD

fn query_with_values<Q: ToString, V: Into<QueryValues>>(     &mut self,     query: Q,     values: V ) -> Result<Frame>

Executes a query with bounded values (either with or without names).

fn query_with_values_tw<Q: ToString, V: Into<QueryValues>>(     &mut self,     query: Q,     values: V,     with_tracing: bool,     with_warnings: bool ) -> Result<Frame>

Executes a query with bounded values (either with or without names) and ability to see warnings, trace a request and default parameters.

fn query_with_params<Q: ToString>(     &mut self,     query: Q,     query_params: QueryParams ) -> Result<Frame>

Executes a query with query params without warnings and tracing.

impl<'a, T: CDRSTransport + 'a, LB: LoadBalancingStrategy<T> + Sized, A: Authenticator + Sized> PrepareExecutor<'a, T> for Session<LB, A>

fn prepare_tw<Q: ToString>(     &'a mut self,     query: Q,     with_tracing: bool,     with_warnings: bool ) -> Result<PreparedQuery>

It prepares a query for execution, along with query itself the method takes with_tracing and with_warnings flags to get tracing information and warnings.

fn prepare<Q: ToString>(&'a mut self, query: Q) -> Result<PreparedQuery>

It prepares query without additional tracing information and warnings.

impl<'a, T: CDRSTransport + 'a, LB: LoadBalancingStrategy<T> + Sized, A: Authenticator + Sized> ExecExecutor<'a, T> for Session<LB, A>

fn exec_with_params_tw(     &mut self,     prepared: &CBytesShort,     query_parameters: QueryParams,     with_tracing: bool,     with_warnings: bool ) -> Result<Frame>

fn exec_with_params(     &mut self,     prepared: &CBytesShort,     query_parameters: QueryParams ) -> Result<Frame>

fn exec_with_values_tw<V: Into<QueryValues>>(     &mut self,     prepared: &CBytesShort,     values: V,     with_tracing: bool,     with_warnings: bool ) -> Result<Frame>

fn exec_with_values<V: Into<QueryValues>>(     &mut self,     prepared: &CBytesShort,     values: V ) -> Result<Frame>

fn exec_tw(     &mut self,     prepared: &CBytesShort,     with_tracing: bool,     with_warnings: bool ) -> Result<Frame>

fn exec(&'a mut self, prepared: &CBytesShort) -> Result<Frame>

impl<'a, T: CDRSTransport + 'a, LB: LoadBalancingStrategy<T> + Sized, A: Authenticator + Sized> BatchExecutor<'a, T> for Session<LB, A>

fn batch_with_params_tw(     &mut self,     batch: QueryBatch,     with_tracing: bool,     with_warnings: bool ) -> Result<Frame>

fn batch_with_params(&mut self, batch: QueryBatch) -> Result<Frame>

impl<'a, T: CDRSTransport + 'a, LB: LoadBalancingStrategy<T> + Sized, A: Authenticator + Sized> CDRSSession<'a, T> for Session<LB, A>