Struct CassandraSession

pub(crate) struct CassandraSession {
    persistent: bool,
    cfg: Arc<EnvVars>,
    session: Arc<Session>,
    queries: Arc<PreparedQueries>,
}

All interaction with cassandra goes through this struct.

Fields

persistent: bool

Is the session to the persistent or volatile DB?

cfg: Arc<EnvVars>

Configuration for this session.

session: Arc<Session>

The actual session.

queries: Arc<PreparedQueries>

All prepared queries we can use on this session.

Implementations

impl CassandraSession

pub(crate) fn init()

Initialise the Cassandra Cluster Connections.

pub(crate) fn is_ready() -> bool

Check to see if the Cassandra Indexing DB is ready for use

pub(crate) async fn wait_is_ready(interval: Duration)

Wait for the Cassandra Indexing DB to be ready before continuing

pub(crate) fn get(persistent: bool) -> Option<Arc<CassandraSession>>

Get the session needed to perform a query.

pub(crate) async fn execute_iter<P>( &self, select_query: PreparedSelectQuery, params: P, ) -> Result<QueryPager>

where P: SerializeRow,

Executes a select query with the given parameters.

Returns an iterator that iterates over all the result pages that the query returns.

pub(crate) async fn execute_batch<T: SerializeRow + Debug>( &self, query: PreparedQuery, values: Vec<T>, ) -> Result<Vec<QueryResult>>

Execute a Batch query with the given parameters.

Values should be a Vec of values which implement SerializeRow and they MUST be the same, and must match the query being executed.

This will divide the batch into optimal sized chunks and execute them until all values have been executed or the first error is encountered.

pub(crate) async fn execute_upsert<T: SerializeRow + Debug>( &self, query: PreparedUpsertQuery, value: T, ) -> Result<()>

Execute a query which returns no results, except an error if it fails. Can not be batched, takes a single set of parameters.

pub(crate) fn get_raw_session(&self) -> Arc<Session>

Get underlying Raw Cassandra Session.

Trait Implementations

impl Clone for CassandraSession

fn clone(&self) -> CassandraSession

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.