Struct scyllax::executor::Executor

pub struct Executor<T> {
    pub session: Arc<Session>,
    /* private fields */
}

A Session and a collection of prepared statements.

The Executor is responsible for executing queries.

It coalesces read queries, adding waiters to a pending request. Write queries are executed immediately.

Fields

session: Arc<Session>

Implementations

impl<T: QueryCollection + Clone> Executor<T>

pub async fn new(session: Arc<Session>) -> Result<Self, ScyllaxError>

Creates a new Executor from a Session and a QueryCollection.

pub async fn execute_read<Q>(&self, query: Q) -> Result<Q::Output, ScyllaxError>

where Q: ReadQuery, T: GetPreparedStatement<Q> + GetCoalescingSender<Q>,

Executes a read query and returns the result.

pub async fn read_task<Q>( &self, request_receiver: Receiver<ShardMessage<Q>>, query_runner: Sender<QueryRunnerMessage<Q>> )

where Q: ReadQuery, T: GetPreparedStatement<Q> + GetCoalescingSender<Q>,

internal

the read task is responsible for coalescing requests

pub async fn read_query_runner<Q>( &self, query_receiver: Receiver<QueryRunnerMessage<Q>> )

where Q: Query + ReadQuery + Hash + Send + Sync, T: GetPreparedStatement<Q> + GetCoalescingSender<Q>,

internal

This function is repsonsible for receiving query requests, executing them, and sending the result back to the requestor.

It is spawned by the branch of Executor::read_task that is responsible for coalescing requests.

pub async fn execute_write<Q>( &self, query: Q ) -> Result<QueryResult, ScyllaxError>

where Q: WriteQuery, T: GetPreparedStatement<Q>,

Executes a write query and returns the scylla::QueryResult.

Trait Implementations

impl<T: Clone> Clone for Executor<T>

fn clone(&self) -> Executor<T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for Executor<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T: QueryCollection> Display for Executor<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.