tarantool-rs 0.0.10

Asyncronous tokio-based client for Tarantool
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33

use tarantool_rs::{Connection, Executor, ExecutorExt};

#[tokio::main]
async fn main() -> Result<(), anyhow::Error> {
    pretty_env_logger::init();

    let connection = Connection::builder().build("127.0.0.1:3301").await?;
    connection.clone().ping().await?;

    let tx = connection.transaction().await?;
    let _ = tx.eval("box.space.clients:insert{2}", ()).await?;
    tx.rollback().await?;

    let tx = connection.transaction().await?;
    let _ = tx.eval("box.space.clients:insert{3}", ()).await?;
    drop(tx);

    let tx = connection.transaction().await?;
    let _ = tx.eval("box.space.clients:insert{4}", ()).await?;
    tx.commit().await?;

    let _: Vec<u32> = connection
        .select(
            512,
            0,
            None,
            None,
            Some(tarantool_rs::IteratorType::All),
            (1,),
        )
        .await?;
    Ok(())
}