Trait tarantool_rs::ConnectionLike
source · pub trait ConnectionLike: Sealed {
Show 13 methods
// Required methods
fn send_request<'life0, 'async_trait>(
&'life0 self,
body: impl 'async_trait + RequestBody
) -> Pin<Box<dyn Future<Output = Result<Value, Error>> + '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, Error>> + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
// Provided methods
fn ping<'life0, 'async_trait>(
&'life0 self
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn eval<'life0, 'async_trait, I, T>(
&'life0 self,
expr: I,
args: Vec<Value>
) -> Pin<Box<dyn Future<Output = Result<T, Error>> + 'async_trait>>
where I: Into<Cow<'static, str>> + Send + 'async_trait,
T: DeserializeOwned + 'async_trait,
Self: 'async_trait,
'life0: 'async_trait { ... }
fn call<'life0, 'async_trait, I, T>(
&'life0 self,
function_name: I,
args: Vec<Value>
) -> Pin<Box<dyn Future<Output = Result<T, Error>> + 'async_trait>>
where I: Into<Cow<'static, str>> + Send + 'async_trait,
T: DeserializeOwned + 'async_trait,
Self: 'async_trait,
'life0: 'async_trait { ... }
fn select<'life0, 'async_trait, T>(
&'life0 self,
space_id: u32,
index_id: u32,
limit: Option<u32>,
offset: Option<u32>,
iterator: Option<IteratorType>,
keys: Vec<Value>
) -> Pin<Box<dyn Future<Output = Result<Vec<T>, Error>> + 'async_trait>>
where T: DeserializeOwned + 'async_trait,
Self: 'async_trait,
'life0: 'async_trait { ... }
fn insert<'life0, 'async_trait>(
&'life0 self,
space_id: u32,
tuple: Vec<Value>
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn update<'life0, 'async_trait>(
&'life0 self,
space_id: u32,
index_id: u32,
index_base: Option<u32>,
keys: Vec<Value>,
tuple: Vec<Value>
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn upsert<'life0, 'async_trait>(
&'life0 self,
space_id: u32,
index_base: u32,
ops: Vec<Value>,
tuple: Vec<Value>
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn replace<'life0, 'async_trait>(
&'life0 self,
space_id: u32,
keys: Vec<Value>
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn delete<'life0, 'async_trait>(
&'life0 self,
space_id: u32,
index_id: u32,
keys: Vec<Value>
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
}Required Methods§
sourcefn send_request<'life0, 'async_trait>(
&'life0 self,
body: impl 'async_trait + RequestBody
) -> Pin<Box<dyn Future<Output = Result<Value, Error>> + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn send_request<'life0, 'async_trait>( &'life0 self, body: impl 'async_trait + RequestBody ) -> Pin<Box<dyn Future<Output = Result<Value, Error>> + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,
Send request, receiving raw response body.
It is not recommended to use this method directly, since some requests should be only sent in specific situations and might break connection.
sourcefn stream(&self) -> Stream
fn stream(&self) -> Stream
Get new Stream.
It is safe to create Stream from any type, implementing current trait.
sourcefn transaction_builder(&self) -> TransactionBuilder
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.
sourcefn transaction<'life0, 'async_trait>(
&'life0 self
) -> Pin<Box<dyn Future<Output = Result<Transaction, Error>> + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn transaction<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<Transaction, Error>> + '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.
Provided Methods§
sourcefn ping<'life0, 'async_trait>(
&'life0 self
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn ping<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,
Send PING request (docs).