bigtable_rs 0.2.18

A very simple Google Bigtable client lib in Rust
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
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111

/// Reference:
/// https://github.com/fdeantoni/prost-wkt
/// https://github.com/hyperium/tonic/tree/master/tonic-build
/// https://github.com/tokio-rs/prost/issues/672
fn main() -> Result<(), Box<dyn std::error::Error>> {
    // Conditionally run this build.rs so we do not need protoc dependency
    // for normal build process.
    // Set up env parameter BUILD_BIGTABLE_RS_GOOGLE_PROTO=true
    // whenever we need to update the generated google proto files
    match std::env::var("BUILD_BIGTABLE_RS_GOOGLE_PROTO") {
        Ok(var) => {
            if var != "true" {
                return Ok(());
            }
        }
        Err(_) => return Ok(()),
    }

    println!(
        "cargo:warning=Running build.rs to generate and format Google API Bigtable proto rs files."
    );

    use prost_wkt_build::{FileDescriptorSet, Message};
    use std::{env, path::PathBuf};
    let out = PathBuf::from(env::var("OUT_DIR").unwrap());
    let descriptor_file = out.join("descriptors.bin");

    tonic_build::configure()
        .build_server(false)
        .out_dir("src/google")
        .compile_well_known_types(true)
        .type_attribute(".", "#[serde_with::serde_as]")
        .type_attribute(".", "#[derive(serde::Serialize,serde::Deserialize)]")
        .type_attribute(".", "#[serde(rename_all = \"camelCase\")]")
        .type_attribute(
            ".google.cloud.conformance.bigtable.v2.ReadRowsTest",
            "#[serde(default)]",
        )
        .field_attribute(
            ".google.bigtable.v2.ReadRowsResponse.CellChunk.row_key",
            "#[serde_as(as = \"serde_with::base64::Base64\")]",
        )
        .field_attribute(
            ".google.bigtable.v2.ReadRowsResponse.CellChunk.row_key",
            "#[serde(default)]",
        )
        .field_attribute(
            ".google.bigtable.v2.ReadRowsResponse.CellChunk.qualifier",
            "#[serde_as(as = \"Option<serde_with::base64::Base64>\")]",
        )
        .field_attribute(
            ".google.bigtable.v2.ReadRowsResponse.CellChunk.qualifier",
            "#[serde(default)]",
        )
        .field_attribute(
            ".google.bigtable.v2.ReadRowsResponse.CellChunk.value",
            "#[serde_as(as = \"serde_with::base64::Base64\")]",
        )
        .field_attribute(
            ".google.bigtable.v2.ReadRowsResponse.CellChunk.timestamp_micros",
            "#[serde(default)]",
        )
        .field_attribute(
            ".google.bigtable.v2.ReadRowsResponse.CellChunk.labels",
            "#[serde(default)]",
        )
        .field_attribute(
            ".google.bigtable.v2.ReadRowsResponse.CellChunk.value",
            "#[serde(default)]",
        )
        .field_attribute(
            ".google.bigtable.v2.ReadRowsResponse.CellChunk.timestamp_micros",
            "#[serde_as(as = \"serde_with::DisplayFromStr\")]",
        )
        .field_attribute(
            ".google.bigtable.v2.ReadRowsResponse.CellChunk.value_size",
            "#[serde(default)]",
        )
        .field_attribute(
            ".google.cloud.conformance.bigtable.v2.ReadRowsTest.Result.timestamp_micros",
            "#[serde_as(as = \"serde_with::DisplayFromStr\")]",
        )
        .extern_path(
            ".google.protobuf.BytesValue",
            "::prost::alloc::vec::Vec<u8>",
        )
        .extern_path(
            ".google.protobuf.StringValue",
            "::prost::alloc::string::String",
        )
        .extern_path(".google.protobuf", "::prost_wkt_types")
        .file_descriptor_set_path(&descriptor_file)
        .compile_protos(
            &[
                "../googleapis/google/bigtable/v2/bigtable.proto",
                "../googleapis/test/bigtable_test.proto", // only works with fork https://github.com/liufuyang/googleapis
            ],
            &["../googleapis"],
        )?;

    let descriptor_bytes = std::fs::read(descriptor_file).unwrap();
    let descriptor = FileDescriptorSet::decode(&descriptor_bytes[..]).unwrap();
    prost_wkt_build::add_serde(out, descriptor);

    std::process::Command::new("cargo")
        .arg("fmt")
        .output()
        .expect("Running `cargo fmt` failed");

    Ok(())
}