Struct cdrs::cluster::session::Session

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

CDRS session that holds one pool of authorized connecitons per node. compression field contains data compressor that will be used for decompressing data received from Cassandra server.

Fields

compression: Compression

Methods

impl<'a, LB: Sized> Session<LB>

pub fn paged<T: CDRSTransport + 'static, M: ManageConnection<Connection = RefCell<T>, Error = Error>>(
    &'a self,
    page_size: i32
) -> SessionPager<'a, M, Session<LB>, T> where
    Session<LB>: CDRSSession<'static, T, M>, 

Basing on current session returns new SessionPager that can be used for performing paged queries.

impl<'a, L> Session<L>

pub fn listen<A: Authenticator + 'static + Sized>(
    &self,
    node: &str,
    authenticator: A,
    events: Vec<SimpleServerEvent>
) -> Result<(Listener<RefCell<TransportTcp>>, EventStream)>

Returns new event listener.

Trait Implementations

impl<T: CDRSTransport + Send + Sync + 'static, M: ManageConnection<Connection = RefCell<T>, Error = Error> + Sized, LB: LoadBalancingStrategy<Pool<M>>> GetConnection<T, M> for Session<LB>

fn get_connection(&self) -> Option<PooledConnection<M>>

Returns connection from a load balancer.

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

fn get_compressor(&self) -> Compression

Returns compression that current session has.

impl<'a, T: CDRSTransport + 'static, M: ManageConnection<Connection = RefCell<T>, Error = Error> + Sized, LB: LoadBalancingStrategy<Pool<M>> + Sized> CDRSSession<'a, T, M> for Session<LB>

impl<'a, T: CDRSTransport + 'static, LB: LoadBalancingStrategy<Pool<M>> + Sized, M: ManageConnection<Connection = RefCell<T>, Error = Error> + Sized> BatchExecutor<T, M> for Session<LB>

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

fn batch_with_params(&self, batch: QueryBatch) -> Result<Frame> where
    Self: Sized, 

impl<'a, T: CDRSTransport + 'static, LB: LoadBalancingStrategy<Pool<M>> + Sized, M: ManageConnection<Connection = RefCell<T>, Error = Error> + Sized> ExecExecutor<T, M> for Session<LB>

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

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

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

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

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

fn exec(&mut self, prepared: &CBytesShort) -> Result<Frame> where
    Self: Sized, 

impl<'a, T: CDRSTransport + 'static, LB: LoadBalancingStrategy<Pool<M>> + Sized, M: ManageConnection<Connection = RefCell<T>, Error = Error> + Sized> PrepareExecutor<T, M> for Session<LB>

fn prepare_tw<Q: ToString>(
    &self,
    query: Q,
    with_tracing: bool,
    with_warnings: bool
) -> Result<PreparedQuery> where
    Self: Sized, 

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>(&self, query: Q) -> Result<PreparedQuery> where
    Self: Sized, 

It prepares query without additional tracing information and warnings.

impl<'a, T: CDRSTransport + 'static, M: ManageConnection<Connection = RefCell<T>, Error = Error> + Sized, LB: LoadBalancingStrategy<Pool<M>> + Sized> QueryExecutor<T, M> for Session<LB>

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

fn query<Q: ToString>(&self, query: Q) -> Result<Frame> where
    Self: Sized, 

Executes a query with default parameters: * TDB

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

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

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

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

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

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>(
    &self,
    query: Q,
    query_params: QueryParams
) -> Result<Frame> where
    Self: Sized, 

Executes a query with query params without warnings and tracing.