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
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48

use std::io::Write;

use crate::{
    codec::consts::{keys, RequestType, TransactionIsolationLevel},
    errors::EncodingError,
};

use super::Request;

#[derive(Clone, Debug)]
pub(crate) struct Begin {
    pub timeout_secs: Option<f64>,
    pub transaction_isolation_level: TransactionIsolationLevel,
}

impl Request for Begin {
    fn request_type() -> RequestType
    where
        Self: Sized,
    {
        RequestType::Begin
    }

    // NOTE: `&mut buf: mut` is required since I don't get why compiler complain
    fn encode(&self, mut buf: &mut dyn Write) -> Result<(), EncodingError> {
        let map_len = if self.timeout_secs.is_some() { 2 } else { 1 };
        rmp::encode::write_map_len(&mut buf, map_len)?;
        if let Some(x) = self.timeout_secs {
            rmp::encode::write_pfix(&mut buf, keys::TIMEOUT)?;
            rmp::encode::write_f64(&mut buf, x)?;
        }
        rmp::encode::write_pfix(&mut buf, keys::TXN_ISOLATION)?;
        rmp::encode::write_u8(&mut buf, self.transaction_isolation_level as u8)?;
        Ok(())
    }
}

impl Begin {
    pub(crate) fn new(
        timeout_secs: Option<f64>,
        transaction_isolation_level: TransactionIsolationLevel,
    ) -> Self {
        Self {
            timeout_secs,
            transaction_isolation_level,
        }
    }
}