ydb 0.11.0

Crate contains generated low-level grpc code from YDB API protobuf, used as base for ydb crate
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
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73

#[derive(serde::Serialize)]
pub(crate) struct RawTransactionControl {
    pub commit_tx: bool,
    pub tx_selector: RawTxSelector,
}

#[derive(serde::Serialize)]
pub(crate) enum RawTxSelector {
    Id(String),
    Begin(RawTxSettings),
}

impl From<RawTxSelector> for ydb_grpc::ydb_proto::table::transaction_control::TxSelector {
    fn from(v: RawTxSelector) -> Self {
        use ydb_grpc::ydb_proto::table::transaction_control::TxSelector;
        match v {
            RawTxSelector::Id(id) => TxSelector::TxId(id),
            RawTxSelector::Begin(tx_settings) => TxSelector::BeginTx(tx_settings.into()),
        }
    }
}

#[derive(serde::Serialize)]
pub(crate) struct RawTxSettings {
    pub mode: RawTxMode,
}

impl From<RawTxSettings> for ydb_grpc::ydb_proto::table::TransactionSettings {
    fn from(v: RawTxSettings) -> Self {
        Self {
            tx_mode: Some(v.mode.into()),
        }
    }
}

#[derive(serde::Serialize)]
pub(crate) enum RawTxMode {
    SerializableReadWrite,
    OnlineReadOnly(RawOnlineReadonlySettings),
    StaleReadOnly,
}

impl From<RawTxMode> for ydb_grpc::ydb_proto::table::transaction_settings::TxMode {
    fn from(v: RawTxMode) -> Self {
        use ydb_grpc::ydb_proto::table;
        use ydb_grpc::ydb_proto::table::transaction_settings::TxMode;
        match v {
            RawTxMode::SerializableReadWrite => {
                TxMode::SerializableReadWrite(table::SerializableModeSettings {})
            }
            RawTxMode::OnlineReadOnly(RawOnlineReadonlySettings {
                allow_inconsistent_reads,
            }) => TxMode::OnlineReadOnly(table::OnlineModeSettings {
                allow_inconsistent_reads,
            }),
            RawTxMode::StaleReadOnly => TxMode::StaleReadOnly(table::StaleModeSettings {}),
        }
    }
}

#[derive(serde::Serialize)]
pub(crate) struct RawOnlineReadonlySettings {
    pub allow_inconsistent_reads: bool,
}

impl From<RawTransactionControl> for ydb_grpc::ydb_proto::table::TransactionControl {
    fn from(v: RawTransactionControl) -> Self {
        Self {
            commit_tx: v.commit_tx,
            tx_selector: Some(v.tx_selector.into()),
        }
    }
}