Struct cdrs::cluster::Session [−][src]
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>
[src]
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>,
[src]
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>
[src]
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>>
[src]
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>>
[src]
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>>
[src]
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)>
[src]
pub fn listen(
&mut self,
events: Vec<SimpleServerEvent>
) -> Result<(Listener<TransportTcp>, EventStream)>
Trait Implementations
impl<'a, LB, A> GetCompressor<'a> for Session<LB, A>
[src]
impl<'a, LB, A> GetCompressor<'a> for Session<LB, A>
fn get_compressor(&self) -> Compression
[src]
fn get_compressor(&self) -> Compression
impl<'a, T: CDRSTransport + 'a, LB: LoadBalancingStrategy<T> + Sized, A: Authenticator + Sized> GetTransport<'a, T> for Session<LB, A>
[src]
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>
[src]
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>
[src]
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>
[src]
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>
[src]
fn query<Q: ToString>(&mut self, query: Q) -> Result<Frame>
Executes a query with default parameters: * TDB Read more
fn query_tw<Q: ToString>(
&mut self,
query: Q,
with_tracing: bool,
with_warnings: bool
) -> Result<Frame>
[src]
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 Read more
fn query_with_values<Q: ToString, V: Into<QueryValues>>(
&mut self,
query: Q,
values: V
) -> Result<Frame>
[src]
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>
[src]
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. Read more
fn query_with_params<Q: ToString>(
&mut self,
query: Q,
query_params: QueryParams
) -> Result<Frame>
[src]
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>
[src]
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>
[src]
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. Read more
fn prepare<Q: ToString>(&'a mut self, query: Q) -> Result<PreparedQuery>
[src]
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>
[src]
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>
[src]
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>
[src]
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>
[src]
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>
[src]
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>
[src]
fn exec_tw(
&mut self,
prepared: &CBytesShort,
with_tracing: bool,
with_warnings: bool
) -> Result<Frame>
fn exec(&'a mut self, prepared: &CBytesShort) -> Result<Frame>
[src]
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>
[src]
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>
[src]
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>
[src]
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>
[src]
impl<'a, T: CDRSTransport + 'a, LB: LoadBalancingStrategy<T> + Sized, A: Authenticator + Sized> CDRSSession<'a, T> for Session<LB, A>