ydb 0.16.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

use crate::YdbIssue;
use ydb_grpc::ydb_proto::status_ids::StatusCode;

/// Long-running operation snapshot returned by Operation Service.
#[derive(Debug, Clone)]
#[cfg_attr(not(feature = "force-exhaustive-all"), non_exhaustive)]
pub struct OperationInfo {
    pub id: String,
    pub ready: bool,
    /// YDB status code (`Ydb.StatusIds.StatusCode` protobuf value).
    pub status: i32,
    pub issues: Vec<YdbIssue>,
    /// Consumed units from `cost_info`, when reported by the server.
    pub consumed_units: Option<f64>,
}

impl OperationInfo {
    pub fn status_code(&self) -> Option<StatusCode> {
        StatusCode::try_from(self.status).ok()
    }

    pub fn is_success(&self) -> bool {
        self.status_code() == Some(StatusCode::Success)
    }
}

/// Filter and pagination parameters for [`OperationClient::list_operations`].
#[derive(Debug, Clone)]
#[cfg_attr(not(feature = "force-exhaustive-all"), non_exhaustive)]
pub struct ListOperationsRequest {
    pub kind: String,
    pub page_size: u64,
    pub page_token: String,
}

impl ListOperationsRequest {
    pub fn new(kind: impl Into<String>) -> Self {
        Self {
            kind: kind.into(),
            page_size: 0,
            page_token: String::new(),
        }
    }

    pub fn with_page_size(mut self, page_size: u64) -> Self {
        self.page_size = page_size;
        self
    }

    pub fn with_page_token(mut self, page_token: impl Into<String>) -> Self {
        self.page_token = page_token.into();
        self
    }
}

/// Page of operations from [`OperationClient::list_operations`].
#[derive(Debug, Clone)]
#[cfg_attr(not(feature = "force-exhaustive-all"), non_exhaustive)]
pub struct ListOperationsResult {
    pub operations: Vec<OperationInfo>,
    pub next_page_token: String,
}

/// Well-known `kind` values for [`ListOperationsRequest`].
pub struct OperationKind;

impl OperationKind {
    pub const EXECUTE_QUERY: &'static str = "scriptexec";
    pub const BUILD_INDEX: &'static str = "buildindex";
    pub const IMPORT_FROM_S3: &'static str = "import/s3";
    pub const EXPORT_TO_S3: &'static str = "export/s3";
    pub const EXPORT_TO_YT: &'static str = "export/yt";
}