Trait tarantool_rs::Executor

pub trait Executor: Sealed + Send + Sync + Debug {
    // Required methods
    fn send_encoded_request<'life0, 'async_trait>(
        &'life0 self,
        request: EncodedRequest
    ) -> Pin<Box<dyn Future<Output = Result<Value>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn stream(&self) -> Stream;
    fn transaction_builder(&self) -> TransactionBuilder;
    fn transaction<'life0, 'async_trait>(
        &'life0 self
    ) -> Pin<Box<dyn Future<Output = Result<Transaction>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_cached_sql_statement_id<'life0, 'life1, 'async_trait>(
        &'life0 self,
        statement: &'life1 str
    ) -> Pin<Box<dyn Future<Output = Option<u64>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
}

Type, which can make requests to Tarantool and create streams and transactions.

Required Methods

fn send_encoded_request<'life0, 'async_trait>( &'life0 self, request: EncodedRequest ) -> Pin<Box<dyn Future<Output = Result<Value>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Send encoded request.

fn stream(&self) -> Stream

Get new Stream.

It is safe to create Stream from any type, implementing current trait.

fn transaction_builder(&self) -> TransactionBuilder

Prepare TransactionBuilder, which can be used to override parameters and create Transaction.

It is safe to create TransactionBuilder from any type.

fn transaction<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<Transaction>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Create Transaction with parameters from builder.

It is safe to create Transaction from any type, implementing current trait.

fn get_cached_sql_statement_id<'life0, 'life1, 'async_trait>( &'life0 self, statement: &'life1 str ) -> Pin<Box<dyn Future<Output = Option<u64>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Implementations on Foreign Types

impl<E: Executor + Sealed + Sync + Debug> Executor for &E

fn send_encoded_request<'life0, 'async_trait>( &'life0 self, request: EncodedRequest ) -> Pin<Box<dyn Future<Output = Result<Value>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn stream(&self) -> Stream

fn transaction_builder(&self) -> TransactionBuilder

fn transaction<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<Transaction>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn get_cached_sql_statement_id<'life0, 'life1, 'async_trait>( &'life0 self, statement: &'life1 str ) -> Pin<Box<dyn Future<Output = Option<u64>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

impl<E: Executor + Sealed + Sync + Debug> Executor for &mut E

fn send_encoded_request<'life0, 'async_trait>( &'life0 self, request: EncodedRequest ) -> Pin<Box<dyn Future<Output = Result<Value>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn stream(&self) -> Stream

fn transaction_builder(&self) -> TransactionBuilder

fn transaction<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<Transaction>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn get_cached_sql_statement_id<'life0, 'life1, 'async_trait>( &'life0 self, statement: &'life1 str ) -> Pin<Box<dyn Future<Output = Option<u64>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Implementors

impl Executor for Connection

impl Executor for Stream

impl Executor for Transaction