gaspersic/solana
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Bump tonic, tonic-build, prost, and etcd-client (#24147)

Browse Source 
* Bump tonic, prost, and etcd-client

* Restore doc ignores
This commit is contained in:
Tyera Eulberg
2022-04-08 12:21:45 -04:00
committed by GitHub
parent 689064a4f4
commit d2702201ca
12 changed files with 575 additions and 487 deletions
Download Patch File Download Diff File Expand all files Collapse all files

355
Cargo.lock generated
View File

@ -172,7 +172,7 @@ checksum = "648ed8c8d2ce5409ccd57453d9d1b214b342a0d69376a6feda1fd6cae3299308"
dependencies = [ dependencies = [
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"syn 1.0.81", "syn 1.0.91",
] ]
[[package]] [[package]]
@ -183,7 +183,7 @@ checksum = "061a7acccaa286c011ddc30970520b98fa40e00c9d644633fb26b5fc63a265e3"
dependencies = [ dependencies = [
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"syn 1.0.81", "syn 1.0.91",
] ]
[[package]] [[package]]
@ -203,6 +203,49 @@ version = "1.0.1"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "cdb031dd78e28731d87d56cc8ffef4a8f36ca26c38fe2de700543e627f8a464a" checksum = "cdb031dd78e28731d87d56cc8ffef4a8f36ca26c38fe2de700543e627f8a464a"
[[package]]
name = "axum"
version = "0.5.1"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "47594e438a243791dba58124b6669561f5baa14cb12046641d8008bf035e5a25"
dependencies = [
"async-trait",
"axum-core",
"bitflags",
"bytes",
"futures-util",
"http",
"http-body",
"hyper",
"itoa 1.0.1",
"matchit",
"memchr",
"mime",
"percent-encoding 2.1.0",
"pin-project-lite",
"serde",
"sync_wrapper",
"tokio",
"tower",
"tower-http",
"tower-layer",
"tower-service",
]
[[package]]
name = "axum-core"
version = "0.2.1"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "9a671c9ae99531afdd5d3ee8340b8da547779430689947144c140fc74a740244"
dependencies = [
"async-trait",
"bytes",
"futures-util",
"http",
"http-body",
"mime",
]
[[package]] [[package]]
name = "backoff" name = "backoff"
version = "0.4.0" version = "0.4.0"
@ -406,7 +449,7 @@ dependencies = [
"borsh-schema-derive-internal", "borsh-schema-derive-internal",
"proc-macro-crate 0.1.5", "proc-macro-crate 0.1.5",
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"syn 1.0.81", "syn 1.0.91",
] ]
[[package]] [[package]]
@ -417,7 +460,7 @@ checksum = "5449c28a7b352f2d1e592a8a28bf139bc71afb0764a14f3c02500935d8c44065"
dependencies = [ dependencies = [
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"syn 1.0.81", "syn 1.0.91",
] ]
[[package]] [[package]]
@ -428,7 +471,7 @@ checksum = "cdbd5696d8bfa21d53d9fe39a714a18538bad11492a42d066dbbc395fb1951c0"
dependencies = [ dependencies = [
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"syn 1.0.81", "syn 1.0.91",
] ]
[[package]] [[package]]
@ -509,7 +552,7 @@ checksum = "8e215f8c2f9f79cb53c8335e687ffd07d5bfcb6fe5fc80723762d0be46e7cc54"
dependencies = [ dependencies = [
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"syn 1.0.81", "syn 1.0.91",
] ]
[[package]] [[package]]
@ -723,11 +766,20 @@ version = "3.1.4"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "da95d038ede1a964ce99f49cbe27a7fb538d1da595e4b4f70b8c8f338d17bf16" checksum = "da95d038ede1a964ce99f49cbe27a7fb538d1da595e4b4f70b8c8f338d17bf16"
dependencies = [ dependencies = [
"heck 0.4.0", "heck",
"proc-macro-error", "proc-macro-error",
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"syn 1.0.81", "syn 1.0.91",
]
[[package]]
name = "cmake"
version = "0.1.46"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "b7b858541263efe664aead4a5209a4ae5c5d2811167d4ed4ee0944503f8d2089"
dependencies = [
"cc",
] ]
[[package]] [[package]]
@ -1053,7 +1105,7 @@ checksum = "fcc3dd5e9e9c0b295d6e1e4d811fb6f157d5ffd784b8d202fc62eac8035a770b"
dependencies = [ dependencies = [
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"syn 1.0.81", "syn 1.0.91",
] ]
[[package]] [[package]]
@ -1066,7 +1118,7 @@ dependencies = [
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"rustc_version 0.3.3", "rustc_version 0.3.3",
"syn 1.0.81", "syn 1.0.91",
] ]
[[package]] [[package]]
@ -1224,7 +1276,7 @@ dependencies = [
"enum-ordinalize", "enum-ordinalize",
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"syn 1.0.81", "syn 1.0.91",
] ]
[[package]] [[package]]
@ -1265,7 +1317,7 @@ checksum = "c134c37760b27a871ba422106eedbb8247da973a09e82558bf26d619c882b159"
dependencies = [ dependencies = [
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"syn 1.0.81", "syn 1.0.91",
] ]
[[package]] [[package]]
@ -1278,7 +1330,7 @@ dependencies = [
"num-traits", "num-traits",
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"syn 1.0.81", "syn 1.0.91",
] ]
[[package]] [[package]]
@ -1330,9 +1382,9 @@ dependencies = [
[[package]] [[package]]
name = "etcd-client" name = "etcd-client"
version = "0.8.4" version = "0.9.0"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "585de5039d1ecce74773db49ba4e8107e42be7c2cd0b1a9e7fce27181db7b118" checksum = "4504e955d596cc27543aa77ecb075dec41c7b0c7749fe6b5536a82548f5073b1"
dependencies = [ dependencies = [
"http", "http",
"prost", "prost",
@ -1340,6 +1392,7 @@ dependencies = [
"tokio-stream", "tokio-stream",
"tonic", "tonic",
"tonic-build", "tonic-build",
"tower",
"tower-service", "tower-service",
] ]
@ -1543,7 +1596,7 @@ checksum = "33c1e13800337f4d4d7a316bf45a567dbcb6ffe087f16424852d97e97a91f512"
dependencies = [ dependencies = [
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"syn 1.0.81", "syn 1.0.91",
] ]
[[package]] [[package]]
@ -1721,7 +1774,7 @@ dependencies = [
"indexmap", "indexmap",
"slab", "slab",
"tokio", "tokio",
"tokio-util", "tokio-util 0.6.9",
"tracing", "tracing",
] ]
@ -1749,15 +1802,6 @@ dependencies = [
"ahash", "ahash",
] ]
[[package]]
name = "heck"
version = "0.3.3"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "6d621efb26863f0e9924c6ac577e8275e5e6b77455db64ffa6c65c904e9e132c"
dependencies = [
"unicode-segmentation",
]
[[package]] [[package]]
name = "heck" name = "heck"
version = "0.4.0" version = "0.4.0"
@ -1848,6 +1892,12 @@ dependencies = [
"pin-project-lite", "pin-project-lite",
] ]
[[package]]
name = "http-range-header"
version = "0.3.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "0bfe8eed0a9285ef776bb792479ea3834e8b94e13d615c2f66d03dd50a435a29"
[[package]] [[package]]
name = "httparse" name = "httparse"
version = "1.5.1" version = "1.5.1"
@ -1898,9 +1948,9 @@ checksum = "d87c48c02e0dc5e3b849a2041db3029fd066650f8f717c07bf8ed78ccb895cac"
dependencies = [ dependencies = [
"http", "http",
"hyper", "hyper",
"rustls 0.20.4", "rustls",
"tokio", "tokio",
"tokio-rustls 0.23.2", "tokio-rustls",
] ]
[[package]] [[package]]
@ -2143,7 +2193,7 @@ dependencies = [
"proc-macro-crate 0.1.5", "proc-macro-crate 0.1.5",
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"syn 1.0.81", "syn 1.0.91",
] ]
[[package]] [[package]]
@ -2206,7 +2256,7 @@ dependencies = [
"log", "log",
"tokio", "tokio",
"tokio-stream", "tokio-stream",
"tokio-util", "tokio-util 0.6.9",
"unicase", "unicase",
] ]
@ -2403,6 +2453,12 @@ version = "0.1.9"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "a3e378b66a060d48947b590737b30a1be76706c8dd7b8ba0f2fe3989c68a853f" checksum = "a3e378b66a060d48947b590737b30a1be76706c8dd7b8ba0f2fe3989c68a853f"
[[package]]
name = "matchit"
version = "0.5.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "73cbba799671b762df5a175adf59ce145165747bb891505c43d09aefbbf38beb"
[[package]] [[package]]
name = "memchr" name = "memchr"
version = "2.4.1" version = "2.4.1"
@ -2523,7 +2579,7 @@ checksum = "5a7d5f7076603ebc68de2dc6a650ec331a062a13abaa346975be747bbfa4b789"
dependencies = [ dependencies = [
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"syn 1.0.81", "syn 1.0.91",
] ]
[[package]] [[package]]
@ -2625,7 +2681,7 @@ checksum = "876a53fff98e03a936a674b29568b0e605f06b29372c2489ff4de23f1949743d"
dependencies = [ dependencies = [
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"syn 1.0.81", "syn 1.0.91",
] ]
[[package]] [[package]]
@ -2676,7 +2732,7 @@ dependencies = [
"proc-macro-crate 1.1.0", "proc-macro-crate 1.1.0",
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"syn 1.0.81", "syn 1.0.91",
] ]
[[package]] [[package]]
@ -2802,7 +2858,7 @@ dependencies = [
"proc-macro-error", "proc-macro-error",
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"syn 1.0.81", "syn 1.0.91",
] ]
[[package]] [[package]]
@ -2941,7 +2997,7 @@ dependencies = [
"pest_meta", "pest_meta",
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"syn 1.0.81", "syn 1.0.91",
] ]
[[package]] [[package]]
@ -2995,7 +3051,7 @@ checksum = "6e8fe8163d14ce7f0cdac2e040116f22eac817edabff0be91e8aff7e9accf389"
dependencies = [ dependencies = [
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"syn 1.0.81", "syn 1.0.91",
] ]
[[package]] [[package]]
@ -3084,6 +3140,16 @@ version = "0.2.1"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "bc5c99d529f0d30937f6f4b8a86d988047327bb88d04d2c4afc356de74722131" checksum = "bc5c99d529f0d30937f6f4b8a86d988047327bb88d04d2c4afc356de74722131"
[[package]]
name = "prettyplease"
version = "0.1.9"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "3b83ec2d0af5c5c556257ff52c9f98934e243b9fd39604bfb2a9b75ec2e97f18"
dependencies = [
"proc-macro2 1.0.32",
"syn 1.0.91",
]
[[package]] [[package]]
name = "proc-macro-crate" name = "proc-macro-crate"
version = "0.1.5" version = "0.1.5"
@ -3112,7 +3178,7 @@ dependencies = [
"proc-macro-error-attr", "proc-macro-error-attr",
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"syn 1.0.81", "syn 1.0.91",
"version_check", "version_check",
] ]
@ -3173,9 +3239,9 @@ dependencies = [
[[package]] [[package]]
name = "prost" name = "prost"
version = "0.9.0" version = "0.10.0"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "444879275cb4fd84958b1a1d5420d15e6fcf7c235fe47f053c9c2a80aceb6001" checksum = "1bd5316aa8f5c82add416dfbc25116b84b748a21153f512917e8143640a71bbd"
dependencies = [ dependencies = [
"bytes", "bytes",
"prost-derive", "prost-derive",
@ -3183,12 +3249,14 @@ dependencies = [
[[package]] [[package]]
name = "prost-build" name = "prost-build"
version = "0.9.0" version = "0.10.0"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "62941722fb675d463659e49c4f3fe1fe792ff24fe5bbaa9c08cd3b98a1c354f5" checksum = "328f9f29b82409216decb172d81e936415d21245befa79cd34c3f29d87d1c50b"
dependencies = [ dependencies = [
"bytes", "bytes",
"heck 0.3.3", "cfg-if 1.0.0",
"cmake",
"heck",
"itertools 0.10.3", "itertools 0.10.3",
"lazy_static", "lazy_static",
"log", "log",
@ -3203,22 +3271,22 @@ dependencies = [
[[package]] [[package]]
name = "prost-derive" name = "prost-derive"
version = "0.9.0" version = "0.10.0"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "f9cc1a3263e07e0bf68e96268f37665207b49560d98739662cdfaae215c720fe" checksum = "df35198f0777b75e9ff669737c6da5136b59dba33cf5a010a6d1cc4d56defc6f"
dependencies = [ dependencies = [
"anyhow", "anyhow",
"itertools 0.10.3", "itertools 0.10.3",
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"syn 1.0.81", "syn 1.0.91",
] ]
[[package]] [[package]]
name = "prost-types" name = "prost-types"
version = "0.9.0" version = "0.10.0"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "534b7a0e836e3c482d2693070f982e39e7611da9695d4d1f5a4b186b51faef0a" checksum = "926681c118ae6e512a3ccefd4abbe5521a14f4cc1e207356d4d00c0b7f2006fd"
dependencies = [ dependencies = [
"bytes", "bytes",
"prost", "prost",
@ -3257,11 +3325,11 @@ dependencies = [
"fxhash", "fxhash",
"quinn-proto", "quinn-proto",
"quinn-udp", "quinn-udp",
"rustls 0.20.4", "rustls",
"thiserror", "thiserror",
"tokio", "tokio",
"tracing", "tracing",
"webpki 0.22.0", "webpki",
] ]
[[package]] [[package]]
@ -3274,14 +3342,14 @@ dependencies = [
"fxhash", "fxhash",
"rand 0.8.4", "rand 0.8.4",
"ring", "ring",
"rustls 0.20.4", "rustls",
"rustls-native-certs", "rustls-native-certs",
"rustls-pemfile 0.2.1", "rustls-pemfile 0.2.1",
"slab", "slab",
"thiserror", "thiserror",
"tinyvec", "tinyvec",
"tracing", "tracing",
"webpki 0.22.0", "webpki",
] ]
[[package]] [[package]]
@ -3616,14 +3684,14 @@ dependencies = [
"native-tls", "native-tls",
"percent-encoding 2.1.0", "percent-encoding 2.1.0",
"pin-project-lite", "pin-project-lite",
"rustls 0.20.4", "rustls",
"rustls-pemfile 0.3.0", "rustls-pemfile 0.3.0",
"serde", "serde",
"serde_json", "serde_json",
"serde_urlencoded", "serde_urlencoded",
"tokio", "tokio",
"tokio-native-tls", "tokio-native-tls",
"tokio-rustls 0.23.2", "tokio-rustls",
"url 2.2.2", "url 2.2.2",
"wasm-bindgen", "wasm-bindgen",
"wasm-bindgen-futures", "wasm-bindgen-futures",
@ -3728,19 +3796,6 @@ dependencies = [
"winapi 0.3.9", "winapi 0.3.9",
] ]
[[package]]
name = "rustls"
version = "0.19.1"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "35edb675feee39aec9c99fa5ff985081995a06d594114ae14cbe797ad7b7a6d7"
dependencies = [
"base64 0.13.0",
"log",
"ring",
"sct 0.6.1",
"webpki 0.21.4",
]
[[package]] [[package]]
name = "rustls" name = "rustls"
version = "0.20.4" version = "0.20.4"
@ -3749,8 +3804,8 @@ checksum = "4fbfeb8d0ddb84706bc597a5574ab8912817c52a397f819e5b614e2265206921"
dependencies = [ dependencies = [
"log", "log",
"ring", "ring",
"sct 0.7.0", "sct",
"webpki 0.22.0", "webpki",
] ]
[[package]] [[package]]
@ -3849,17 +3904,7 @@ checksum = "aaaae8f38bb311444cfb7f1979af0bc9240d95795f75f9ceddf6a59b79ceffa0"
dependencies = [ dependencies = [
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"syn 1.0.81", "syn 1.0.91",
]
[[package]]
name = "sct"
version = "0.6.1"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "b362b83898e0e69f38515b82ee15aa80636befe47c3b6d3d89a911e78fc228ce"
dependencies = [
"ring",
"untrusted",
] ]
[[package]] [[package]]
@ -3973,7 +4018,7 @@ checksum = "08597e7152fcd306f41838ed3e37be9eaeed2b61c42e2117266a554fab4662f9"
dependencies = [ dependencies = [
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"syn 1.0.81", "syn 1.0.91",
] ]
[[package]] [[package]]
@ -4032,7 +4077,7 @@ dependencies = [
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"rustversion", "rustversion",
"syn 1.0.81", "syn 1.0.91",
] ]
[[package]] [[package]]
@ -4628,7 +4673,7 @@ dependencies = [
"rand_chacha 0.2.2", "rand_chacha 0.2.2",
"rayon", "rayon",
"reqwest", "reqwest",
"rustls 0.20.4", "rustls",
"semver 1.0.6", "semver 1.0.6",
"serde", "serde",
"serde_derive", "serde_derive",
@ -4902,7 +4947,7 @@ dependencies = [
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"rustc_version 0.2.3", "rustc_version 0.2.3",
"syn 1.0.81", "syn 1.0.91",
] ]
[[package]] [[package]]
@ -4912,7 +4957,7 @@ dependencies = [
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"rustc_version 0.4.0", "rustc_version 0.4.0",
"syn 1.0.81", "syn 1.0.91",
] ]
[[package]] [[package]]
@ -5580,7 +5625,7 @@ dependencies = [
"symlink", "symlink",
"thiserror", "thiserror",
"tokio", "tokio",
"tokio-util", "tokio-util 0.6.9",
] ]
[[package]] [[package]]
@ -5727,7 +5772,7 @@ dependencies = [
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"rustversion", "rustversion",
"syn 1.0.81", "syn 1.0.91",
] ]
[[package]] [[package]]
@ -5738,7 +5783,7 @@ dependencies = [
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"rustversion", "rustversion",
"syn 1.0.81", "syn 1.0.91",
] ]
[[package]] [[package]]
@ -5860,7 +5905,7 @@ dependencies = [
"quinn", "quinn",
"rand 0.7.3", "rand 0.7.3",
"rcgen", "rcgen",
"rustls 0.20.4", "rustls",
"solana-logger 1.11.0", "solana-logger 1.11.0",
"solana-metrics", "solana-metrics",
"solana-perf", "solana-perf",
@ -6259,7 +6304,7 @@ dependencies = [
"quote 1.0.10", "quote 1.0.10",
"serde", "serde",
"serde_derive", "serde_derive",
"syn 1.0.81", "syn 1.0.91",
] ]
[[package]] [[package]]
@ -6275,7 +6320,7 @@ dependencies = [
"serde_derive", "serde_derive",
"serde_json", "serde_json",
"sha1", "sha1",
"syn 1.0.81", "syn 1.0.91",
] ]
[[package]] [[package]]
@ -6332,15 +6377,21 @@ dependencies = [
[[package]] [[package]]
name = "syn" name = "syn"
version = "1.0.81" version = "1.0.91"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "f2afee18b8beb5a596ecb4a2dce128c719b4ba399d34126b9e4396e3f9860966" checksum = "b683b2b825c8eef438b77c36a06dc262294da3d5a5813fac20da149241dcd44d"
dependencies = [ dependencies = [
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"unicode-xid 0.2.2", "unicode-xid 0.2.2",
] ]
[[package]]
name = "sync_wrapper"
version = "0.1.1"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "20518fe4a4c9acf048008599e464deb21beeae3d3578418951a189c235a7a9a8"
[[package]] [[package]]
name = "synstructure" name = "synstructure"
version = "0.12.6" version = "0.12.6"
@ -6349,7 +6400,7 @@ checksum = "f36bdaa60a83aca3921b5259d5400cbf5e90fc51931376a9bd4a0eb79aa7210f"
dependencies = [ dependencies = [
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"syn 1.0.81", "syn 1.0.91",
"unicode-xid 0.2.2", "unicode-xid 0.2.2",
] ]
@ -6426,7 +6477,7 @@ dependencies = [
"thiserror", "thiserror",
"tokio", "tokio",
"tokio-serde", "tokio-serde",
"tokio-util", "tokio-util 0.6.9",
"tracing", "tracing",
"tracing-opentelemetry", "tracing-opentelemetry",
] ]
@ -6439,7 +6490,7 @@ checksum = "0ee42b4e559f17bce0385ebf511a7beb67d5cc33c12c96b7f4e9789919d9c10f"
dependencies = [ dependencies = [
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"syn 1.0.81", "syn 1.0.91",
] ]
[[package]] [[package]]
@ -6513,7 +6564,7 @@ checksum = "aa32fd3f627f367fe16f893e2597ae3c05020f8bba2666a4e6ea73d377e5714b"
dependencies = [ dependencies = [
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"syn 1.0.81", "syn 1.0.91",
] ]
[[package]] [[package]]
@ -6607,7 +6658,7 @@ dependencies = [
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"standback", "standback",
"syn 1.0.81", "syn 1.0.91",
] ]
[[package]] [[package]]
@ -6682,7 +6733,7 @@ checksum = "b557f72f448c511a979e2564e55d74e6c4432fc96ff4f6241bc6bded342643b7"
dependencies = [ dependencies = [
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"syn 1.0.81", "syn 1.0.91",
] ]
[[package]] [[package]]
@ -6695,26 +6746,15 @@ dependencies = [
"tokio", "tokio",
] ]
[[package]]
name = "tokio-rustls"
version = "0.22.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "bc6844de72e57df1980054b38be3a9f4702aba4858be64dd700181a8a6d0e1b6"
dependencies = [
"rustls 0.19.1",
"tokio",
"webpki 0.21.4",
]
[[package]] [[package]]
name = "tokio-rustls" name = "tokio-rustls"
version = "0.23.2" version = "0.23.2"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "a27d5f2b839802bd8267fa19b0530f5a08b9c08cd417976be2a65d130fe1c11b" checksum = "a27d5f2b839802bd8267fa19b0530f5a08b9c08cd417976be2a65d130fe1c11b"
dependencies = [ dependencies = [
"rustls 0.20.4", "rustls",
"tokio", "tokio",
"webpki 0.22.0", "webpki",
] ]
[[package]] [[package]]
@ -6752,11 +6792,11 @@ checksum = "06cda1232a49558c46f8a504d5b93101d42c0bf7f911f12a105ba48168f821ae"
dependencies = [ dependencies = [
"futures-util", "futures-util",
"log", "log",
"rustls 0.20.4", "rustls",
"tokio", "tokio",
"tokio-rustls 0.23.2", "tokio-rustls",
"tungstenite", "tungstenite",
"webpki 0.22.0", "webpki",
"webpki-roots", "webpki-roots",
] ]
@ -6776,6 +6816,20 @@ dependencies = [
"tokio", "tokio",
] ]
[[package]]
name = "tokio-util"
version = "0.7.1"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "0edfdeb067411dba2044da6d1cb2df793dd35add7888d73c16e3381ded401764"
dependencies = [
"bytes",
"futures-core",
"futures-sink",
"pin-project-lite",
"tokio",
"tracing",
]
[[package]] [[package]]
name = "toml" name = "toml"
version = "0.5.8" version = "0.5.8"
@ -6787,12 +6841,13 @@ dependencies = [
[[package]] [[package]]
name = "tonic" name = "tonic"
version = "0.6.2" version = "0.7.1"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "ff08f4649d10a70ffa3522ca559031285d8e421d727ac85c60825761818f5d0a" checksum = "30fb54bf1e446f44d870d260d99957e7d11fb9d0a0f5bd1a662ad1411cc103f9"
dependencies = [ dependencies = [
"async-stream", "async-stream",
"async-trait", "async-trait",
"axum",
"base64 0.13.0", "base64 0.13.0",
"bytes", "bytes",
"futures-core", "futures-core",
@ -6806,10 +6861,11 @@ dependencies = [
"pin-project", "pin-project",
"prost", "prost",
"prost-derive", "prost-derive",
"rustls-pemfile 0.3.0",
"tokio", "tokio",
"tokio-rustls 0.22.0", "tokio-rustls",
"tokio-stream", "tokio-stream",
"tokio-util", "tokio-util 0.7.1",
"tower", "tower",
"tower-layer", "tower-layer",
"tower-service", "tower-service",
@ -6819,21 +6875,22 @@ dependencies = [
[[package]] [[package]]
name = "tonic-build" name = "tonic-build"
version = "0.6.2" version = "0.7.0"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "9403f1bafde247186684b230dc6f38b5cd514584e8bec1dd32514be4745fa757" checksum = "4d17087af5c80e5d5fc8ba9878e60258065a0a757e35efe7a05b7904bece1943"
dependencies = [ dependencies = [
"prettyplease",
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"prost-build", "prost-build",
"quote 1.0.10", "quote 1.0.10",
"syn 1.0.81", "syn 1.0.91",
] ]
[[package]] [[package]]
name = "tower" name = "tower"
version = "0.4.10" version = "0.4.12"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "c00e500fff5fa1131c866b246041a6bf96da9c965f8fe4128cb1421f23e93c00" checksum = "9a89fd63ad6adf737582df5db40d286574513c69a11dac5214dc3b5603d6713e"
dependencies = [ dependencies = [
"futures-core", "futures-core",
"futures-util", "futures-util",
@ -6843,13 +6900,31 @@ dependencies = [
"rand 0.8.4", "rand 0.8.4",
"slab", "slab",
"tokio", "tokio",
"tokio-stream", "tokio-util 0.7.1",
"tokio-util",
"tower-layer", "tower-layer",
"tower-service", "tower-service",
"tracing", "tracing",
] ]
[[package]]
name = "tower-http"
version = "0.2.5"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "aba3f3efabf7fb41fae8534fc20a817013dd1c12cb45441efb6c82e6556b4cd8"
dependencies = [
"bitflags",
"bytes",
"futures-core",
"futures-util",
"http",
"http-body",
"http-range-header",
"pin-project-lite",
"tower",
"tower-layer",
"tower-service",
]
[[package]] [[package]]
name = "tower-layer" name = "tower-layer"
version = "0.3.1" version = "0.3.1"
@ -6883,7 +6958,7 @@ checksum = "f4f480b8f81512e825f337ad51e94c1eb5d3bbdf2b363dcd01e2b19a9ffe3f8e"
dependencies = [ dependencies = [
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"syn 1.0.81", "syn 1.0.91",
] ]
[[package]] [[package]]
@ -6953,12 +7028,12 @@ dependencies = [
"httparse", "httparse",
"log", "log",
"rand 0.8.4", "rand 0.8.4",
"rustls 0.20.4", "rustls",
"sha-1 0.10.0", "sha-1 0.10.0",
"thiserror", "thiserror",
"url 2.2.2", "url 2.2.2",
"utf-8", "utf-8",
"webpki 0.22.0", "webpki",
"webpki-roots", "webpki-roots",
] ]
@ -6998,12 +7073,6 @@ dependencies = [
"tinyvec", "tinyvec",
] ]
[[package]]
name = "unicode-segmentation"
version = "1.8.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "8895849a949e7845e06bd6dc1aa51731a103c42707010a5b591c0038fb73385b"
[[package]] [[package]]
name = "unicode-width" name = "unicode-width"
version = "0.1.9" version = "0.1.9"
@ -7198,7 +7267,7 @@ dependencies = [
"log", "log",
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"syn 1.0.81", "syn 1.0.91",
"wasm-bindgen-shared", "wasm-bindgen-shared",
] ]
@ -7232,7 +7301,7 @@ checksum = "7803e0eea25835f8abdc585cd3021b3deb11543c6fe226dcd30b228857c5c5ab"
dependencies = [ dependencies = [
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"syn 1.0.81", "syn 1.0.91",
"wasm-bindgen-backend", "wasm-bindgen-backend",
"wasm-bindgen-shared", "wasm-bindgen-shared",
] ]
@ -7253,16 +7322,6 @@ dependencies = [
"wasm-bindgen", "wasm-bindgen",
] ]
[[package]]
name = "webpki"
version = "0.21.4"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "b8e38c0608262c46d4a56202ebabdeb094cef7e560ca7a226c6bf055188aa4ea"
dependencies = [
"ring",
"untrusted",
]
[[package]] [[package]]
name = "webpki" name = "webpki"
version = "0.22.0" version = "0.22.0"
@ -7279,7 +7338,7 @@ version = "0.22.1"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "c475786c6f47219345717a043a37ec04cb4bc185e28853adcc4fa0a947eba630" checksum = "c475786c6f47219345717a043a37ec04cb4bc185e28853adcc4fa0a947eba630"
dependencies = [ dependencies = [
"webpki 0.22.0", "webpki",
] ]
[[package]] [[package]]
@ -7481,7 +7540,7 @@ checksum = "bdff2024a851a322b08f179173ae2ba620445aef1e838f0c196820eade4ae0c7"
dependencies = [ dependencies = [
"proc-macro2 1.0.32", "proc-macro2 1.0.32",
"quote 1.0.10", "quote 1.0.10",
"syn 1.0.81", "syn 1.0.91",
"synstructure", "synstructure",
] ]

2
core/Cargo.toml
View File

@ -21,7 +21,7 @@ bs58 = "0.4.0"
chrono = { version = "0.4.11", features = ["serde"] } chrono = { version = "0.4.11", features = ["serde"] }
crossbeam-channel = "0.5" crossbeam-channel = "0.5"
dashmap = { version = "4.0.2", features = ["rayon", "raw-api"] } dashmap = { version = "4.0.2", features = ["rayon", "raw-api"] }
etcd-client = { version = "0.8.4", features = ["tls"] } etcd-client = { version = "0.9.0", features = ["tls"] }
fs_extra = "1.2.0" fs_extra = "1.2.0"
histogram = "0.6.9" histogram = "0.6.9"
itertools = "0.10.3" itertools = "0.10.3"

2
ledger/Cargo.toml
View File

@ -26,7 +26,7 @@ lru = "0.7.5"
num-derive = "0.3" num-derive = "0.3"
num-traits = "0.2" num-traits = "0.2"
num_cpus = "1.13.1" num_cpus = "1.13.1"
prost = "0.9.0" prost = "0.10.0"
rand = "0.7.0" rand = "0.7.0"
rand_chacha = "0.2.2" rand_chacha = "0.2.2"
rayon = "1.5.1" rayon = "1.5.1"

6
storage-bigtable/Cargo.toml
View File

@ -17,8 +17,8 @@ enum-iterator = "0.7.0"
flate2 = "1.0.22" flate2 = "1.0.22"
goauth = "0.11.1" goauth = "0.11.1"
log = "0.4.14" log = "0.4.14"
prost = "0.9.0" prost = "0.10.0"
prost-types = "0.9.0" prost-types = "0.10.0"
serde = "1.0.136" serde = "1.0.136"
serde_derive = "1.0.103" serde_derive = "1.0.103"
smpl_jwt = "0.6.1" smpl_jwt = "0.6.1"
@ -27,7 +27,7 @@ solana-sdk = { path = "../sdk", version = "=1.11.0" }
solana-storage-proto = { path = "../storage-proto", version = "=1.11.0" } solana-storage-proto = { path = "../storage-proto", version = "=1.11.0" }
solana-transaction-status = { path = "../transaction-status", version = "=1.11.0" } solana-transaction-status = { path = "../transaction-status", version = "=1.11.0" }
thiserror = "1.0" thiserror = "1.0"
tonic = { version = "0.6.2", features = ["tls", "transport"] } tonic = { version = "0.7.1", features = ["tls", "transport"] }
zstd = "0.11.1" zstd = "0.11.1"
# openssl is a dependency of the goauth and smpl_jwt crates, but explicitly # openssl is a dependency of the goauth and smpl_jwt crates, but explicitly

88
storage-bigtable/build-proto/Cargo.lock generated
View File

@ -2,15 +2,6 @@
# It is not intended for manual editing. # It is not intended for manual editing.
version = 3 version = 3
[[package]]
name = "aho-corasick"
version = "0.7.18"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "1e37cfd5e7657ada45f742d6e99ca5788580b5c529dc78faf11ece6dc702656f"
dependencies = [
"memchr",
]
[[package]] [[package]]
name = "anyhow" name = "anyhow"
version = "1.0.56" version = "1.0.56"
@ -35,6 +26,12 @@ version = "1.0.1"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "b700ce4376041dcd0a327fd0097c41095743c4c8af8887265942faf1100bd040" checksum = "b700ce4376041dcd0a327fd0097c41095743c4c8af8887265942faf1100bd040"
[[package]]
name = "cc"
version = "1.0.73"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "2fff2a6927b3bb87f9595d67196a70493f627687a71d87a0d692242c33f58c11"
[[package]] [[package]]
name = "cfg-if" name = "cfg-if"
version = "0.1.10" version = "0.1.10"
@ -47,6 +44,15 @@ version = "1.0.0"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "baf1de4339761588bc0619e3cbc0120ee582ebb74b53b4efbf79117bd2da40fd" checksum = "baf1de4339761588bc0619e3cbc0120ee582ebb74b53b4efbf79117bd2da40fd"
[[package]]
name = "cmake"
version = "0.1.48"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "e8ad8cef104ac57b68b89df3208164d228503abbdce70f6880ffa3d970e7443a"
dependencies = [
"cc",
]
[[package]] [[package]]
name = "either" name = "either"
version = "1.5.3" version = "1.5.3"
@ -76,12 +82,9 @@ checksum = "ab5ef0d4909ef3724cc8cce6ccc8572c5c817592e9285f5464f8e86f8bd3726e"
[[package]] [[package]]
name = "heck" name = "heck"
version = "0.3.1" version = "0.4.0"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "20564e78d53d2bb135c343b3f47714a56af2061f1c928fdb541dc7b9fdd94205" checksum = "2540771e65fc8cb83cd6e8a237f70c319bd5c29f78ed1084ba5d50eeac86f7f9"
dependencies = [
"unicode-segmentation",
]
[[package]] [[package]]
name = "indexmap" name = "indexmap"
@ -132,12 +135,6 @@ dependencies = [
"cfg-if 0.1.10", "cfg-if 0.1.10",
] ]
[[package]]
name = "memchr"
version = "2.4.1"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "308cc39be01b73d0d18f82a0e7b2a3df85245f84af96fdddc5d202d27e47b86a"
[[package]] [[package]]
name = "multimap" name = "multimap"
version = "0.8.1" version = "0.8.1"
@ -155,19 +152,29 @@ dependencies = [
] ]
[[package]] [[package]]
name = "proc-macro2" name = "prettyplease"
version = "1.0.27" version = "0.1.9"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "f0d8caf72986c1a598726adc988bb5984792ef84f5ee5aa50209145ee8077038" checksum = "3b83ec2d0af5c5c556257ff52c9f98934e243b9fd39604bfb2a9b75ec2e97f18"
dependencies = [
"proc-macro2",
"syn",
]
[[package]]
name = "proc-macro2"
version = "1.0.36"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "c7342d5883fbccae1cc37a2353b09c87c9b0f3afd73f5fb9bba687a1f733b029"
dependencies = [ dependencies = [
"unicode-xid", "unicode-xid",
] ]
[[package]] [[package]]
name = "prost" name = "prost"
version = "0.9.0" version = "0.10.0"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "444879275cb4fd84958b1a1d5420d15e6fcf7c235fe47f053c9c2a80aceb6001" checksum = "1bd5316aa8f5c82add416dfbc25116b84b748a21153f512917e8143640a71bbd"
dependencies = [ dependencies = [
"bytes", "bytes",
"prost-derive", "prost-derive",
@ -175,11 +182,13 @@ dependencies = [
[[package]] [[package]]
name = "prost-build" name = "prost-build"
version = "0.9.0" version = "0.10.0"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "62941722fb675d463659e49c4f3fe1fe792ff24fe5bbaa9c08cd3b98a1c354f5" checksum = "328f9f29b82409216decb172d81e936415d21245befa79cd34c3f29d87d1c50b"
dependencies = [ dependencies = [
"bytes", "bytes",
"cfg-if 1.0.0",
"cmake",
"heck", "heck",
"itertools", "itertools",
"lazy_static", "lazy_static",
@ -195,9 +204,9 @@ dependencies = [
[[package]] [[package]]
name = "prost-derive" name = "prost-derive"
version = "0.9.0" version = "0.10.0"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "f9cc1a3263e07e0bf68e96268f37665207b49560d98739662cdfaae215c720fe" checksum = "df35198f0777b75e9ff669737c6da5136b59dba33cf5a010a6d1cc4d56defc6f"
dependencies = [ dependencies = [
"anyhow", "anyhow",
"itertools", "itertools",
@ -208,9 +217,9 @@ dependencies = [
[[package]] [[package]]
name = "prost-types" name = "prost-types"
version = "0.9.0" version = "0.10.0"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "534b7a0e836e3c482d2693070f982e39e7611da9695d4d1f5a4b186b51faef0a" checksum = "926681c118ae6e512a3ccefd4abbe5521a14f4cc1e207356d4d00c0b7f2006fd"
dependencies = [ dependencies = [
"bytes", "bytes",
"prost", "prost",
@ -247,8 +256,6 @@ version = "1.5.5"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "1a11647b6b25ff05a515cb92c365cec08801e83423a235b51e231e1808747286" checksum = "1a11647b6b25ff05a515cb92c365cec08801e83423a235b51e231e1808747286"
dependencies = [ dependencies = [
"aho-corasick",
"memchr",
"regex-syntax", "regex-syntax",
] ]
@ -269,9 +276,9 @@ dependencies = [
[[package]] [[package]]
name = "syn" name = "syn"
version = "1.0.73" version = "1.0.91"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "f71489ff30030d2ae598524f61326b902466f72a0fb1a8564c001cc63425bcc7" checksum = "b683b2b825c8eef438b77c36a06dc262294da3d5a5813fac20da149241dcd44d"
dependencies = [ dependencies = [
"proc-macro2", "proc-macro2",
"quote", "quote",
@ -314,22 +321,17 @@ dependencies = [
[[package]] [[package]]
name = "tonic-build" name = "tonic-build"
version = "0.6.2" version = "0.7.0"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "9403f1bafde247186684b230dc6f38b5cd514584e8bec1dd32514be4745fa757" checksum = "4d17087af5c80e5d5fc8ba9878e60258065a0a757e35efe7a05b7904bece1943"
dependencies = [ dependencies = [
"prettyplease",
"proc-macro2", "proc-macro2",
"prost-build", "prost-build",
"quote", "quote",
"syn", "syn",
] ]
[[package]]
name = "unicode-segmentation"
version = "1.6.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "e83e153d1053cbb5a118eeff7fd5be06ed99153f00dbcd8ae310c5fb2b22edc0"
[[package]] [[package]]
name = "unicode-xid" name = "unicode-xid"
version = "0.2.1" version = "0.2.1"

2
storage-bigtable/build-proto/Cargo.toml
View File

@ -12,4 +12,4 @@ version = "1.11.0"
[workspace] [workspace]
[dependencies] [dependencies]
tonic-build = "0.6.0" tonic-build = "0.7.0"

1
storage-bigtable/build-proto/src/main.rs
View File

@ -10,7 +10,6 @@ fn main() -> Result<(), std::io::Error> {
tonic_build::configure() tonic_build::configure()
.build_client(true) .build_client(true)
.build_server(false) .build_server(false)
.format(true)
.out_dir(&out_dir) .out_dir(&out_dir)
.compile( .compile(
&[googleapis.join("google/bigtable/v2/bigtable.proto")], &[googleapis.join("google/bigtable/v2/bigtable.proto")],

48
storage-bigtable/proto/google.api.rs
View File

@ -1,5 +1,5 @@
/// Defines the HTTP configuration for an API service. It contains a list of /// Defines the HTTP configuration for an API service. It contains a list of
/// [HttpRule][google.api.HttpRule], each specifying the mapping of an RPC method /// \[HttpRule][google.api.HttpRule\], each specifying the mapping of an RPC method
/// to one or more HTTP REST API methods. /// to one or more HTTP REST API methods.
#[derive(Clone, PartialEq, ::prost::Message)] #[derive(Clone, PartialEq, ::prost::Message)]
pub struct Http { pub struct Http {
@ -22,10 +22,10 @@ pub struct Http {
/// gRPC Transcoding is a feature for mapping between a gRPC method and one or /// gRPC Transcoding is a feature for mapping between a gRPC method and one or
/// more HTTP REST endpoints. It allows developers to build a single API service /// more HTTP REST endpoints. It allows developers to build a single API service
/// that supports both gRPC APIs and REST APIs. Many systems, including [Google /// that supports both gRPC APIs and REST APIs. Many systems, including [Google
/// APIs](https://github.com/googleapis/googleapis), /// APIs](<https://github.com/googleapis/googleapis>),
/// [Cloud Endpoints](https://cloud.google.com/endpoints), [gRPC /// [Cloud Endpoints](<https://cloud.google.com/endpoints>), [gRPC
/// Gateway](https://github.com/grpc-ecosystem/grpc-gateway), /// Gateway](<https://github.com/grpc-ecosystem/grpc-gateway>),
/// and [Envoy](https://github.com/envoyproxy/envoy) proxy support this feature /// and \[Envoy\](<https://github.com/envoyproxy/envoy>) proxy support this feature
/// and use it for large scale production services. /// and use it for large scale production services.
/// ///
/// `HttpRule` defines the schema of the gRPC/REST mapping. The mapping specifies /// `HttpRule` defines the schema of the gRPC/REST mapping. The mapping specifies
@ -186,15 +186,15 @@ pub struct Http {
/// 1. Leaf request fields (recursive expansion nested messages in the request /// 1. Leaf request fields (recursive expansion nested messages in the request
/// message) are classified into three categories: /// message) are classified into three categories:
/// - Fields referred by the path template. They are passed via the URL path. /// - Fields referred by the path template. They are passed via the URL path.
/// - Fields referred by the [HttpRule.body][google.api.HttpRule.body]. They are passed via the HTTP /// - Fields referred by the \[HttpRule.body][google.api.HttpRule.body\]. They are passed via the HTTP
/// request body. /// request body.
/// - All other fields are passed via the URL query parameters, and the /// - All other fields are passed via the URL query parameters, and the
/// parameter name is the field path in the request message. A repeated /// parameter name is the field path in the request message. A repeated
/// field can be represented as multiple query parameters under the same /// field can be represented as multiple query parameters under the same
/// name. /// name.
/// 2. If [HttpRule.body][google.api.HttpRule.body] is "*", there is no URL query parameter, all fields /// 2. If \[HttpRule.body][google.api.HttpRule.body\] is "*", there is no URL query parameter, all fields
/// are passed via URL path and HTTP request body. /// are passed via URL path and HTTP request body.
/// 3. If [HttpRule.body][google.api.HttpRule.body] is omitted, there is no HTTP request body, all /// 3. If \[HttpRule.body][google.api.HttpRule.body\] is omitted, there is no HTTP request body, all
/// fields are passed via URL path and URL query parameters. /// fields are passed via URL path and URL query parameters.
/// ///
/// ### Path template syntax /// ### Path template syntax
@ -221,19 +221,19 @@ pub struct Http {
/// ///
/// If a variable contains exactly one path segment, such as `"{var}"` or /// If a variable contains exactly one path segment, such as `"{var}"` or
/// `"{var=*}"`, when such a variable is expanded into a URL path on the client /// `"{var=*}"`, when such a variable is expanded into a URL path on the client
/// side, all characters except `[-_.~0-9a-zA-Z]` are percent-encoded. The /// side, all characters except `\[-_.~0-9a-zA-Z\]` are percent-encoded. The
/// server side does the reverse decoding. Such variables show up in the /// server side does the reverse decoding. Such variables show up in the
/// [Discovery /// [Discovery
/// Document](https://developers.google.com/discovery/v1/reference/apis) as /// Document](<https://developers.google.com/discovery/v1/reference/apis>) as
/// `{var}`. /// `{var}`.
/// ///
/// If a variable contains multiple path segments, such as `"{var=foo/*}"` /// If a variable contains multiple path segments, such as `"{var=foo/*}"`
/// or `"{var=**}"`, when such a variable is expanded into a URL path on the /// or `"{var=**}"`, when such a variable is expanded into a URL path on the
/// client side, all characters except `[-_.~/0-9a-zA-Z]` are percent-encoded. /// client side, all characters except `\[-_.~/0-9a-zA-Z\]` are percent-encoded.
/// The server side does the reverse decoding, except "%2F" and "%2f" are left /// The server side does the reverse decoding, except "%2F" and "%2f" are left
/// unchanged. Such variables show up in the /// unchanged. Such variables show up in the
/// [Discovery /// [Discovery
/// Document](https://developers.google.com/discovery/v1/reference/apis) as /// Document](<https://developers.google.com/discovery/v1/reference/apis>) as
/// `{+var}`. /// `{+var}`.
/// ///
/// ## Using gRPC API Service Configuration /// ## Using gRPC API Service Configuration
@ -263,10 +263,10 @@ pub struct Http {
/// ///
/// When gRPC Transcoding is used to map a gRPC to JSON REST endpoints, the /// When gRPC Transcoding is used to map a gRPC to JSON REST endpoints, the
/// proto to JSON conversion must follow the [proto3 /// proto to JSON conversion must follow the [proto3
/// specification](https://developers.google.com/protocol-buffers/docs/proto3#json). /// specification](<https://developers.google.com/protocol-buffers/docs/proto3#json>).
/// ///
/// While the single segment variable follows the semantics of /// While the single segment variable follows the semantics of
/// [RFC 6570](https://tools.ietf.org/html/rfc6570) Section 3.2.2 Simple String /// [RFC 6570](<https://tools.ietf.org/html/rfc6570>) Section 3.2.2 Simple String
/// Expansion, the multi segment variable **does not** follow RFC 6570 Section /// Expansion, the multi segment variable **does not** follow RFC 6570 Section
/// 3.2.3 Reserved Expansion. The reason is that the Reserved Expansion /// 3.2.3 Reserved Expansion. The reason is that the Reserved Expansion
/// does not expand special characters like `?` and `#`, which would lead /// does not expand special characters like `?` and `#`, which would lead
@ -290,7 +290,7 @@ pub struct Http {
pub struct HttpRule { pub struct HttpRule {
/// Selects a method to which this rule applies. /// Selects a method to which this rule applies.
/// ///
/// Refer to [selector][google.api.DocumentationRule.selector] for syntax details. /// Refer to \[selector][google.api.DocumentationRule.selector\] for syntax details.
#[prost(string, tag="1")] #[prost(string, tag="1")]
pub selector: ::prost::alloc::string::String, pub selector: ::prost::alloc::string::String,
/// The name of the request field whose value is mapped to the HTTP request /// The name of the request field whose value is mapped to the HTTP request
@ -393,6 +393,16 @@ pub enum FieldBehavior {
/// This indicates that the field may be set once in a request to create a /// This indicates that the field may be set once in a request to create a
/// resource, but may not be changed thereafter. /// resource, but may not be changed thereafter.
Immutable = 5, Immutable = 5,
/// Denotes that a (repeated) field is an unordered list.
/// This indicates that the service may provide the elements of the list
/// in any arbitrary order, rather than the order the user originally
/// provided. Additionally, the list's order may or may not be stable.
UnorderedList = 6,
/// Denotes that this field returns a non-empty default value if not set.
/// This indicates that if the user provides the empty value in a request,
/// a non-empty value will be returned. The user will not be aware of what
/// non-empty value to expect.
NonEmptyDefault = 7,
} }
/// A simple descriptor of a resource type. /// A simple descriptor of a resource type.
/// ///
@ -511,7 +521,7 @@ pub struct ResourceDescriptor {
/// Example: `storage.googleapis.com/Bucket` /// Example: `storage.googleapis.com/Bucket`
/// ///
/// The value of the resource_type_kind must follow the regular expression /// The value of the resource_type_kind must follow the regular expression
/// /[A-Za-z][a-zA-Z0-9]+/. It should start with an upper case character and /// /\[A-Za-z][a-zA-Z0-9\]+/. It should start with an upper case character and
/// should use PascalCase (UpperCamelCase). The maximum number of /// should use PascalCase (UpperCamelCase). The maximum number of
/// characters allowed for the `resource_type_kind` is 100. /// characters allowed for the `resource_type_kind` is 100.
#[prost(string, tag="1")] #[prost(string, tag="1")]
@ -562,14 +572,14 @@ pub struct ResourceDescriptor {
/// 'projects' for the resource name of 'projects/{project}' and the permission /// 'projects' for the resource name of 'projects/{project}' and the permission
/// name of 'cloudresourcemanager.googleapis.com/projects.get'. It is the same /// name of 'cloudresourcemanager.googleapis.com/projects.get'. It is the same
/// concept of the `plural` field in k8s CRD spec /// concept of the `plural` field in k8s CRD spec
/// https://kubernetes.io/docs/tasks/access-kubernetes-api/custom-resources/custom-resource-definitions/ /// <https://kubernetes.io/docs/tasks/access-kubernetes-api/custom-resources/custom-resource-definitions/>
/// ///
/// Note: The plural form is required even for singleton resources. See /// Note: The plural form is required even for singleton resources. See
/// https://aip.dev/156 /// <https://aip.dev/156>
#[prost(string, tag="5")] #[prost(string, tag="5")]
pub plural: ::prost::alloc::string::String, pub plural: ::prost::alloc::string::String,
/// The same concept of the `singular` field in k8s CRD spec /// The same concept of the `singular` field in k8s CRD spec
/// https://kubernetes.io/docs/tasks/access-kubernetes-api/custom-resources/custom-resource-definitions/ /// <https://kubernetes.io/docs/tasks/access-kubernetes-api/custom-resources/custom-resource-definitions/>
/// Such as "project" for the `resourcemanager.googleapis.com/Project` type. /// Such as "project" for the `resourcemanager.googleapis.com/Project` type.
#[prost(string, tag="6")] #[prost(string, tag="6")]
pub singular: ::prost::alloc::string::String, pub singular: ::prost::alloc::string::String,

187
storage-bigtable/proto/google.bigtable.v2.rs
View File

@ -19,7 +19,7 @@ pub struct Family {
/// The unique key which identifies this family within its row. This is the /// The unique key which identifies this family within its row. This is the
/// same key that's used to identify the family in, for example, a RowFilter /// same key that's used to identify the family in, for example, a RowFilter
/// which sets its "family_name_regex_filter" field. /// which sets its "family_name_regex_filter" field.
/// Must match `[-_.a-zA-Z0-9]+`, except that AggregatingRowProcessors may /// Must match `\[-_.a-zA-Z0-9\]+`, except that AggregatingRowProcessors may
/// produce cells in a sentinel family with an empty name. /// produce cells in a sentinel family with an empty name.
/// Must be no greater than 64 characters in length. /// Must be no greater than 64 characters in length.
#[prost(string, tag="1")] #[prost(string, tag="1")]
@ -59,7 +59,7 @@ pub struct Cell {
/// length. /// length.
#[prost(bytes="vec", tag="2")] #[prost(bytes="vec", tag="2")]
pub value: ::prost::alloc::vec::Vec<u8>, pub value: ::prost::alloc::vec::Vec<u8>,
/// Labels applied to the cell by a [RowFilter][google.bigtable.v2.RowFilter]. /// Labels applied to the cell by a \[RowFilter][google.bigtable.v2.RowFilter\].
#[prost(string, repeated, tag="3")] #[prost(string, repeated, tag="3")]
pub labels: ::prost::alloc::vec::Vec<::prost::alloc::string::String>, pub labels: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
} }
@ -215,10 +215,10 @@ pub mod value_range {
/// * True filters alter the input row by excluding some of its cells wholesale /// * True filters alter the input row by excluding some of its cells wholesale
/// from the output row. An example of a true filter is the `value_regex_filter`, /// from the output row. An example of a true filter is the `value_regex_filter`,
/// which excludes cells whose values don't match the specified pattern. All /// which excludes cells whose values don't match the specified pattern. All
/// regex true filters use RE2 syntax (https://github.com/google/re2/wiki/Syntax) /// regex true filters use RE2 syntax (<https://github.com/google/re2/wiki/Syntax>)
/// in raw byte mode (RE2::Latin1), and are evaluated as full matches. An /// in raw byte mode (RE2::Latin1), and are evaluated as full matches. An
/// important point to keep in mind is that `RE2(.)` is equivalent by default to /// important point to keep in mind is that `RE2(.)` is equivalent by default to
/// `RE2([^\n])`, meaning that it does not match newlines. When attempting to /// `RE2(\[^\n\])`, meaning that it does not match newlines. When attempting to
/// match an arbitrary byte, you should therefore use the escape sequence `\C`, /// match an arbitrary byte, you should therefore use the escape sequence `\C`,
/// which may need to be further escaped as `\\C` in your client language. /// which may need to be further escaped as `\\C` in your client language.
/// ///
@ -237,14 +237,10 @@ pub mod value_range {
pub struct RowFilter { pub struct RowFilter {
/// Which of the possible RowFilter types to apply. If none are set, this /// Which of the possible RowFilter types to apply. If none are set, this
/// RowFilter returns all cells in the input row. /// RowFilter returns all cells in the input row.
#[prost( #[prost(oneof="row_filter::Filter", tags="1, 2, 3, 16, 17, 18, 4, 14, 5, 6, 7, 8, 9, 15, 10, 11, 12, 13, 19")]
oneof = "row_filter::Filter",
tags = "1, 2, 3, 16, 17, 18, 4, 14, 5, 6, 7, 8, 9, 15, 10, 11, 12, 13, 19"
)]
pub filter: ::core::option::Option<row_filter::Filter>, pub filter: ::core::option::Option<row_filter::Filter>,
} }
/// Nested message and enum types in `RowFilter`. /// Nested message and enum types in `RowFilter`.
#[allow(clippy::enum_variant_names)]
pub mod row_filter { pub mod row_filter {
/// A RowFilter which sends rows through several RowFilters in sequence. /// A RowFilter which sends rows through several RowFilters in sequence.
#[derive(Clone, PartialEq, ::prost::Message)] #[derive(Clone, PartialEq, ::prost::Message)]
@ -353,13 +349,13 @@ pub mod row_filter {
/// | | /// | |
/// All() Label(foo) /// All() Label(foo)
/// | | /// | |
/// A,A,1,w A,A,1,w,labels:[foo] /// A,A,1,w A,A,1,w,labels:\[foo\]
/// A,B,2,x A,B,2,x,labels:[foo] /// A,B,2,x A,B,2,x,labels:\[foo\]
/// | | /// | |
/// | Sink() --------------+ /// | Sink() --------------+
/// | | | /// | | |
/// +------------+ x------+ A,A,1,w,labels:[foo] /// +------------+ x------+ A,A,1,w,labels:\[foo\]
/// | A,B,2,x,labels:[foo] /// | A,B,2,x,labels:\[foo\]
/// A,A,1,w | /// A,A,1,w |
/// A,B,2,x | /// A,B,2,x |
/// | | /// | |
@ -369,14 +365,14 @@ pub mod row_filter {
/// | | /// | |
/// +--------------------------------+ /// +--------------------------------+
/// | /// |
/// A,A,1,w,labels:[foo] /// A,A,1,w,labels:\[foo\]
/// A,B,2,x,labels:[foo] // could be switched /// A,B,2,x,labels:\[foo\] // could be switched
/// A,B,2,x // could be switched /// A,B,2,x // could be switched
/// ///
/// Despite being excluded by the qualifier filter, a copy of every cell /// Despite being excluded by the qualifier filter, a copy of every cell
/// that reaches the sink is present in the final result. /// that reaches the sink is present in the final result.
/// ///
/// As with an [Interleave][google.bigtable.v2.RowFilter.Interleave], /// As with an \[Interleave][google.bigtable.v2.RowFilter.Interleave\],
/// duplicate cells are possible, and appear in an unspecified mutual order. /// duplicate cells are possible, and appear in an unspecified mutual order.
/// In this case we have a duplicate with column "A:B" and timestamp 2, /// In this case we have a duplicate with column "A:B" and timestamp 2,
/// because one copy passed through the all filter while the other was /// because one copy passed through the all filter while the other was
@ -384,7 +380,7 @@ pub mod row_filter {
/// while the other does not. /// while the other does not.
/// ///
/// Cannot be used within the `predicate_filter`, `true_filter`, or /// Cannot be used within the `predicate_filter`, `true_filter`, or
/// `false_filter` of a [Condition][google.bigtable.v2.RowFilter.Condition]. /// `false_filter` of a \[Condition][google.bigtable.v2.RowFilter.Condition\].
#[prost(bool, tag="16")] #[prost(bool, tag="16")]
Sink(bool), Sink(bool),
/// Matches all cells, regardless of input. Functionally equivalent to /// Matches all cells, regardless of input. Functionally equivalent to
@ -466,7 +462,7 @@ pub mod row_filter {
/// the filter. /// the filter.
/// ///
/// Values must be at most 15 characters in length, and match the RE2 /// Values must be at most 15 characters in length, and match the RE2
/// pattern `[a-z0-9\\-]+` /// pattern `\[a-z0-9\\-\]+`
/// ///
/// Due to a technical limitation, it is not currently possible to apply /// Due to a technical limitation, it is not currently possible to apply
/// multiple labels to a cell. As a result, a Chain may have no more than /// multiple labels to a cell. As a result, a Chain may have no more than
@ -491,7 +487,7 @@ pub mod mutation {
#[derive(Clone, PartialEq, ::prost::Message)] #[derive(Clone, PartialEq, ::prost::Message)]
pub struct SetCell { pub struct SetCell {
/// The name of the family into which new data should be written. /// The name of the family into which new data should be written.
/// Must match `[-_.a-zA-Z0-9]+` /// Must match `\[-_.a-zA-Z0-9\]+`
#[prost(string, tag="1")] #[prost(string, tag="1")]
pub family_name: ::prost::alloc::string::String, pub family_name: ::prost::alloc::string::String,
/// The qualifier of the column into which new data should be written. /// The qualifier of the column into which new data should be written.
@ -514,7 +510,7 @@ pub mod mutation {
#[derive(Clone, PartialEq, ::prost::Message)] #[derive(Clone, PartialEq, ::prost::Message)]
pub struct DeleteFromColumn { pub struct DeleteFromColumn {
/// The name of the family from which cells should be deleted. /// The name of the family from which cells should be deleted.
/// Must match `[-_.a-zA-Z0-9]+` /// Must match `\[-_.a-zA-Z0-9\]+`
#[prost(string, tag="1")] #[prost(string, tag="1")]
pub family_name: ::prost::alloc::string::String, pub family_name: ::prost::alloc::string::String,
/// The qualifier of the column from which cells should be deleted. /// The qualifier of the column from which cells should be deleted.
@ -529,13 +525,14 @@ pub mod mutation {
#[derive(Clone, PartialEq, ::prost::Message)] #[derive(Clone, PartialEq, ::prost::Message)]
pub struct DeleteFromFamily { pub struct DeleteFromFamily {
/// The name of the family from which cells should be deleted. /// The name of the family from which cells should be deleted.
/// Must match `[-_.a-zA-Z0-9]+` /// Must match `\[-_.a-zA-Z0-9\]+`
#[prost(string, tag="1")] #[prost(string, tag="1")]
pub family_name: ::prost::alloc::string::String, pub family_name: ::prost::alloc::string::String,
} }
/// A Mutation which deletes all cells from the containing row. /// A Mutation which deletes all cells from the containing row.
#[derive(Clone, PartialEq, ::prost::Message)] #[derive(Clone, PartialEq, ::prost::Message)]
pub struct DeleteFromRow {} pub struct DeleteFromRow {
}
/// Which of the possible Mutation types to apply. /// Which of the possible Mutation types to apply.
#[derive(Clone, PartialEq, ::prost::Oneof)] #[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Mutation { pub enum Mutation {
@ -558,7 +555,7 @@ pub mod mutation {
#[derive(Clone, PartialEq, ::prost::Message)] #[derive(Clone, PartialEq, ::prost::Message)]
pub struct ReadModifyWriteRule { pub struct ReadModifyWriteRule {
/// The name of the family to which the read/modify/write should be applied. /// The name of the family to which the read/modify/write should be applied.
/// Must match `[-_.a-zA-Z0-9]+` /// Must match `\[-_.a-zA-Z0-9\]+`
#[prost(string, tag="1")] #[prost(string, tag="1")]
pub family_name: ::prost::alloc::string::String, pub family_name: ::prost::alloc::string::String,
/// The qualifier of the column to which the read/modify/write should be /// The qualifier of the column to which the read/modify/write should be
@ -668,7 +665,7 @@ pub mod read_rows_response {
#[prost(int64, tag="4")] #[prost(int64, tag="4")]
pub timestamp_micros: i64, pub timestamp_micros: i64,
/// Labels applied to the cell by a /// Labels applied to the cell by a
/// [RowFilter][google.bigtable.v2.RowFilter]. Labels are only set /// \[RowFilter][google.bigtable.v2.RowFilter\]. Labels are only set
/// on the first CellChunk per cell. /// on the first CellChunk per cell.
#[prost(string, repeated, tag="5")] #[prost(string, repeated, tag="5")]
pub labels: ::prost::alloc::vec::Vec<::prost::alloc::string::String>, pub labels: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
@ -760,7 +757,8 @@ pub struct MutateRowRequest {
} }
/// Response message for Bigtable.MutateRow. /// Response message for Bigtable.MutateRow.
#[derive(Clone, PartialEq, ::prost::Message)] #[derive(Clone, PartialEq, ::prost::Message)]
pub struct MutateRowResponse {} pub struct MutateRowResponse {
}
/// Request message for BigtableService.MutateRows. /// Request message for BigtableService.MutateRows.
#[derive(Clone, PartialEq, ::prost::Message)] #[derive(Clone, PartialEq, ::prost::Message)]
pub struct MutateRowsRequest { pub struct MutateRowsRequest {
@ -893,17 +891,17 @@ pub struct ReadModifyWriteRowResponse {
#[prost(message, optional, tag="1")] #[prost(message, optional, tag="1")]
pub row: ::core::option::Option<Row>, pub row: ::core::option::Option<Row>,
} }
#[doc = r" Generated client implementations."] /// Generated client implementations.
pub mod bigtable_client { pub mod bigtable_client {
#![allow(unused_variables, dead_code, missing_docs)] #![allow(unused_variables, dead_code, missing_docs, clippy::let_unit_value)]
use tonic::codegen::*; use tonic::codegen::*;
#[doc = " Service for reading from and writing to existing Bigtable tables."] /// Service for reading from and writing to existing Bigtable tables.
#[derive(Debug, Clone)] #[derive(Debug, Clone)]
pub struct BigtableClient<T> { pub struct BigtableClient<T> {
inner: tonic::client::Grpc<T>, inner: tonic::client::Grpc<T>,
} }
impl BigtableClient<tonic::transport::Channel> { impl BigtableClient<tonic::transport::Channel> {
#[doc = r" Attempt to create a new client by connecting to a given endpoint."] /// Attempt to create a new client by connecting to a given endpoint.
pub async fn connect<D>(dst: D) -> Result<Self, tonic::transport::Error> pub async fn connect<D>(dst: D) -> Result<Self, tonic::transport::Error>
where where
D: std::convert::TryInto<tonic::transport::Endpoint>, D: std::convert::TryInto<tonic::transport::Endpoint>,
@ -916,8 +914,8 @@ pub mod bigtable_client {
impl<T> BigtableClient<T> impl<T> BigtableClient<T>
where where
T: tonic::client::GrpcService<tonic::body::BoxBody>, T: tonic::client::GrpcService<tonic::body::BoxBody>,
T::ResponseBody: Body + Send + Sync + 'static,
T::Error: Into<StdError>, T::Error: Into<StdError>,
T::ResponseBody: Default + Body<Data = Bytes> + Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + Send, <T::ResponseBody as Body>::Error: Into<StdError> + Send,
{ {
pub fn new(inner: T) -> Self { pub fn new(inner: T) -> Self {
@ -929,58 +927,65 @@ pub mod bigtable_client {
interceptor: F, interceptor: F,
) -> BigtableClient<InterceptedService<T, F>> ) -> BigtableClient<InterceptedService<T, F>>
where where
F: FnMut(tonic::Request<()>) -> Result<tonic::Request<()>, tonic::Status>, F: tonic::service::Interceptor,
T: Service< T: tonic::codegen::Service<
http::Request<tonic::body::BoxBody>, http::Request<tonic::body::BoxBody>,
Response = http::Response< Response = http::Response<
<T as tonic::client::GrpcService<tonic::body::BoxBody>>::ResponseBody, <T as tonic::client::GrpcService<tonic::body::BoxBody>>::ResponseBody,
>, >,
>, >,
<T as Service<http::Request<tonic::body::BoxBody>>>::Error: <T as tonic::codegen::Service<
Into<StdError> + Send + Sync, http::Request<tonic::body::BoxBody>,
>>::Error: Into<StdError> + Send + Sync,
{ {
BigtableClient::new(InterceptedService::new(inner, interceptor)) BigtableClient::new(InterceptedService::new(inner, interceptor))
} }
#[doc = r" Compress requests with `gzip`."] /// Compress requests with `gzip`.
#[doc = r""] ///
#[doc = r" This requires the server to support it otherwise it might respond with an"] /// This requires the server to support it otherwise it might respond with an
#[doc = r" error."] /// error.
#[must_use]
pub fn send_gzip(mut self) -> Self { pub fn send_gzip(mut self) -> Self {
self.inner = self.inner.send_gzip(); self.inner = self.inner.send_gzip();
self self
} }
#[doc = r" Enable decompressing responses with `gzip`."] /// Enable decompressing responses with `gzip`.
#[must_use]
pub fn accept_gzip(mut self) -> Self { pub fn accept_gzip(mut self) -> Self {
self.inner = self.inner.accept_gzip(); self.inner = self.inner.accept_gzip();
self self
} }
#[doc = " Streams back the contents of all requested rows in key order, optionally"] /// Streams back the contents of all requested rows in key order, optionally
#[doc = " applying the same Reader filter to each. Depending on their size,"] /// applying the same Reader filter to each. Depending on their size,
#[doc = " rows and cells may be broken up across multiple responses, but"] /// rows and cells may be broken up across multiple responses, but
#[doc = " atomicity of each row will still be preserved. See the"] /// atomicity of each row will still be preserved. See the
#[doc = " ReadRowsResponse documentation for details."] /// ReadRowsResponse documentation for details.
pub async fn read_rows( pub async fn read_rows(
&mut self, &mut self,
request: impl tonic::IntoRequest<super::ReadRowsRequest>, request: impl tonic::IntoRequest<super::ReadRowsRequest>,
) -> Result<tonic::Response<tonic::codec::Streaming<super::ReadRowsResponse>>, tonic::Status> ) -> Result<
{ tonic::Response<tonic::codec::Streaming<super::ReadRowsResponse>>,
self.inner.ready().await.map_err(|e| { tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::new( tonic::Status::new(
tonic::Code::Unknown, tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
let codec = tonic::codec::ProstCodec::default(); let codec = tonic::codec::ProstCodec::default();
let path = let path = http::uri::PathAndQuery::from_static(
http::uri::PathAndQuery::from_static("/google.bigtable.v2.Bigtable/ReadRows"); "/google.bigtable.v2.Bigtable/ReadRows",
self.inner );
.server_streaming(request.into_request(), path, codec) self.inner.server_streaming(request.into_request(), path, codec).await
.await
} }
#[doc = " Returns a sample of row keys in the table. The returned row keys will"] /// Returns a sample of row keys in the table. The returned row keys will
#[doc = " delimit contiguous sections of the table of approximately equal size,"] /// delimit contiguous sections of the table of approximately equal size,
#[doc = " which can be used to break up the data for distributed tasks like"] /// which can be used to break up the data for distributed tasks like
#[doc = " mapreduces."] /// mapreduces.
pub async fn sample_row_keys( pub async fn sample_row_keys(
&mut self, &mut self,
request: impl tonic::IntoRequest<super::SampleRowKeysRequest>, request: impl tonic::IntoRequest<super::SampleRowKeysRequest>,
@ -988,39 +993,45 @@ pub mod bigtable_client {
tonic::Response<tonic::codec::Streaming<super::SampleRowKeysResponse>>, tonic::Response<tonic::codec::Streaming<super::SampleRowKeysResponse>>,
tonic::Status, tonic::Status,
> { > {
self.inner.ready().await.map_err(|e| { self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::new( tonic::Status::new(
tonic::Code::Unknown, tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
let codec = tonic::codec::ProstCodec::default(); let codec = tonic::codec::ProstCodec::default();
let path = let path = http::uri::PathAndQuery::from_static(
http::uri::PathAndQuery::from_static("/google.bigtable.v2.Bigtable/SampleRowKeys"); "/google.bigtable.v2.Bigtable/SampleRowKeys",
self.inner );
.server_streaming(request.into_request(), path, codec) self.inner.server_streaming(request.into_request(), path, codec).await
.await
} }
#[doc = " Mutates a row atomically. Cells already present in the row are left"] /// Mutates a row atomically. Cells already present in the row are left
#[doc = " unchanged unless explicitly changed by `mutation`."] /// unchanged unless explicitly changed by `mutation`.
pub async fn mutate_row( pub async fn mutate_row(
&mut self, &mut self,
request: impl tonic::IntoRequest<super::MutateRowRequest>, request: impl tonic::IntoRequest<super::MutateRowRequest>,
) -> Result<tonic::Response<super::MutateRowResponse>, tonic::Status> { ) -> Result<tonic::Response<super::MutateRowResponse>, tonic::Status> {
self.inner.ready().await.map_err(|e| { self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::new( tonic::Status::new(
tonic::Code::Unknown, tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
let codec = tonic::codec::ProstCodec::default(); let codec = tonic::codec::ProstCodec::default();
let path = let path = http::uri::PathAndQuery::from_static(
http::uri::PathAndQuery::from_static("/google.bigtable.v2.Bigtable/MutateRow"); "/google.bigtable.v2.Bigtable/MutateRow",
);
self.inner.unary(request.into_request(), path, codec).await self.inner.unary(request.into_request(), path, codec).await
} }
#[doc = " Mutates multiple rows in a batch. Each individual row is mutated"] /// Mutates multiple rows in a batch. Each individual row is mutated
#[doc = " atomically as in MutateRow, but the entire batch is not executed"] /// atomically as in MutateRow, but the entire batch is not executed
#[doc = " atomically."] /// atomically.
pub async fn mutate_rows( pub async fn mutate_rows(
&mut self, &mut self,
request: impl tonic::IntoRequest<super::MutateRowsRequest>, request: impl tonic::IntoRequest<super::MutateRowsRequest>,
@ -1028,25 +1039,30 @@ pub mod bigtable_client {
tonic::Response<tonic::codec::Streaming<super::MutateRowsResponse>>, tonic::Response<tonic::codec::Streaming<super::MutateRowsResponse>>,
tonic::Status, tonic::Status,
> { > {
self.inner.ready().await.map_err(|e| { self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::new( tonic::Status::new(
tonic::Code::Unknown, tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
let codec = tonic::codec::ProstCodec::default(); let codec = tonic::codec::ProstCodec::default();
let path = let path = http::uri::PathAndQuery::from_static(
http::uri::PathAndQuery::from_static("/google.bigtable.v2.Bigtable/MutateRows"); "/google.bigtable.v2.Bigtable/MutateRows",
self.inner );
.server_streaming(request.into_request(), path, codec) self.inner.server_streaming(request.into_request(), path, codec).await
.await
} }
#[doc = " Mutates a row atomically based on the output of a predicate Reader filter."] /// Mutates a row atomically based on the output of a predicate Reader filter.
pub async fn check_and_mutate_row( pub async fn check_and_mutate_row(
&mut self, &mut self,
request: impl tonic::IntoRequest<super::CheckAndMutateRowRequest>, request: impl tonic::IntoRequest<super::CheckAndMutateRowRequest>,
) -> Result<tonic::Response<super::CheckAndMutateRowResponse>, tonic::Status> { ) -> Result<tonic::Response<super::CheckAndMutateRowResponse>, tonic::Status> {
self.inner.ready().await.map_err(|e| { self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::new( tonic::Status::new(
tonic::Code::Unknown, tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
@ -1058,16 +1074,19 @@ pub mod bigtable_client {
); );
self.inner.unary(request.into_request(), path, codec).await self.inner.unary(request.into_request(), path, codec).await
} }
#[doc = " Modifies a row atomically on the server. The method reads the latest"] /// Modifies a row atomically on the server. The method reads the latest
#[doc = " existing timestamp and value from the specified columns and writes a new"] /// existing timestamp and value from the specified columns and writes a new
#[doc = " entry based on pre-defined read/modify/write rules. The new value for the"] /// entry based on pre-defined read/modify/write rules. The new value for the
#[doc = " timestamp is the greater of the existing timestamp or the current server"] /// timestamp is the greater of the existing timestamp or the current server
#[doc = " time. The method returns the new contents of all modified cells."] /// time. The method returns the new contents of all modified cells.
pub async fn read_modify_write_row( pub async fn read_modify_write_row(
&mut self, &mut self,
request: impl tonic::IntoRequest<super::ReadModifyWriteRowRequest>, request: impl tonic::IntoRequest<super::ReadModifyWriteRowRequest>,
) -> Result<tonic::Response<super::ReadModifyWriteRowResponse>, tonic::Status> { ) -> Result<tonic::Response<super::ReadModifyWriteRowResponse>, tonic::Status> {
self.inner.ready().await.map_err(|e| { self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::new( tonic::Status::new(
tonic::Code::Unknown, tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),

8
storage-bigtable/proto/google.rpc.rs
View File

@ -1,18 +1,18 @@
/// The `Status` type defines a logical error model that is suitable for /// The `Status` type defines a logical error model that is suitable for
/// different programming environments, including REST APIs and RPC APIs. It is /// different programming environments, including REST APIs and RPC APIs. It is
/// used by [gRPC](https://github.com/grpc). Each `Status` message contains /// used by \[gRPC\](<https://github.com/grpc>). Each `Status` message contains
/// three pieces of data: error code, error message, and error details. /// three pieces of data: error code, error message, and error details.
/// ///
/// You can find out more about this error model and how to work with it in the /// You can find out more about this error model and how to work with it in the
/// [API Design Guide](https://cloud.google.com/apis/design/errors). /// [API Design Guide](<https://cloud.google.com/apis/design/errors>).
#[derive(Clone, PartialEq, ::prost::Message)] #[derive(Clone, PartialEq, ::prost::Message)]
pub struct Status { pub struct Status {
/// The status code, which should be an enum value of [google.rpc.Code][google.rpc.Code]. /// The status code, which should be an enum value of \[google.rpc.Code][google.rpc.Code\].
#[prost(int32, tag="1")] #[prost(int32, tag="1")]
pub code: i32, pub code: i32,
/// A developer-facing error message, which should be in English. Any /// A developer-facing error message, which should be in English. Any
/// user-facing error message should be localized and sent in the /// user-facing error message should be localized and sent in the
/// [google.rpc.Status.details][google.rpc.Status.details] field, or localized by the client. /// \[google.rpc.Status.details][google.rpc.Status.details\] field, or localized by the client.
#[prost(string, tag="2")] #[prost(string, tag="2")]
pub message: ::prost::alloc::string::String, pub message: ::prost::alloc::string::String,
/// A list of messages that carry the error details. There is a common set of /// A list of messages that carry the error details. There is a common set of

4
storage-proto/Cargo.toml
View File

@ -12,7 +12,7 @@ edition = "2021"
[dependencies] [dependencies]
bincode = "1.3.3" bincode = "1.3.3"
bs58 = "0.4.0" bs58 = "0.4.0"
prost = "0.9.0" prost = "0.10.0"
serde = "1.0.136" serde = "1.0.136"
solana-account-decoder = { path = "../account-decoder", version = "=1.11.0" } solana-account-decoder = { path = "../account-decoder", version = "=1.11.0" }
solana-sdk = { path = "../sdk", version = "=1.11.0" } solana-sdk = { path = "../sdk", version = "=1.11.0" }
@ -29,4 +29,4 @@ name = "solana_storage_proto"
targets = ["x86_64-unknown-linux-gnu"] targets = ["x86_64-unknown-linux-gnu"]
[build-dependencies] [build-dependencies]
tonic-build = "0.6.2" tonic-build = "0.7.0"

1
storage-proto/build.rs
View File

@ -11,7 +11,6 @@ fn main() -> Result<(), std::io::Error> {
tonic_build::configure() tonic_build::configure()
.build_client(true) .build_client(true)
.build_server(false) .build_server(false)
.format(true)
.type_attribute( .type_attribute(
"TransactionErrorType", "TransactionErrorType",
"#[cfg_attr(test, derive(enum_iterator::IntoEnumIterator))]", "#[cfg_attr(test, derive(enum_iterator::IntoEnumIterator))]",