Struct tarantool_rs::Transaction

pub struct Transaction { /* private fields */ }

Started transaction (docs).

If tranasction have a timeout and no requests made for that time, tranasction is automatically rolled back.

On drop tranasaction is rolled back, if not have been commited or rolled back already.

Implementations

impl Transaction

pub async fn commit(self) -> Result<(), Error>

Commit tranasction.

pub async fn rollback(self) -> Result<(), Error>

Rollback tranasction.

Trait Implementations

impl ConnectionLike for Transaction

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.

fn stream(&self) -> Stream

Get new Stream.

fn transaction_builder(&self) -> TransactionBuilder

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

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.

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).

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,

impl Drop for Transaction

fn drop(&mut self)

Executes the destructor for this type.