ydb 0.13.3

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

use ydb_grpc::ydb_proto::query::{
    transaction_control, transaction_settings, OnlineModeSettings, SerializableModeSettings,
    SnapshotModeSettings, SnapshotRwModeSettings, StaleModeSettings, TransactionControl,
    TransactionSettings,
};

#[derive(Clone, Copy, Debug, PartialEq, Eq)]
pub(crate) enum RawQueryTxMode {
    SerializableReadWrite,
    SnapshotReadOnly,
    SnapshotReadWrite,
    StaleReadOnly,
    OnlineReadOnly,
}

pub(crate) fn begin_tx_control(mode: RawQueryTxMode, commit_tx: bool) -> TransactionControl {
    TransactionControl {
        commit_tx,
        tx_selector: Some(transaction_control::TxSelector::BeginTx(tx_settings(mode))),
    }
}

pub(crate) fn tx_id_control(tx_id: &str, commit_tx: bool) -> TransactionControl {
    TransactionControl {
        commit_tx,
        tx_selector: Some(transaction_control::TxSelector::TxId(tx_id.to_string())),
    }
}

pub(crate) fn tx_settings_for_mode(mode: RawQueryTxMode) -> TransactionSettings {
    tx_settings(mode)
}

fn tx_settings(mode: RawQueryTxMode) -> TransactionSettings {
    let tx_mode = match mode {
        RawQueryTxMode::SerializableReadWrite => {
            transaction_settings::TxMode::SerializableReadWrite(SerializableModeSettings {})
        }
        RawQueryTxMode::SnapshotReadOnly => {
            transaction_settings::TxMode::SnapshotReadOnly(SnapshotModeSettings {})
        }
        RawQueryTxMode::SnapshotReadWrite => {
            transaction_settings::TxMode::SnapshotReadWrite(SnapshotRwModeSettings {})
        }
        RawQueryTxMode::StaleReadOnly => {
            transaction_settings::TxMode::StaleReadOnly(StaleModeSettings {})
        }
        RawQueryTxMode::OnlineReadOnly => {
            // Public API does not expose allow_inconsistent_reads; keep stale-replica reads disabled.
            transaction_settings::TxMode::OnlineReadOnly(OnlineModeSettings {
                allow_inconsistent_reads: false,
            })
        }
    };
    TransactionSettings {
        tx_mode: Some(tx_mode),
    }
}