gsadmin/rustfs
1
0
Fork 0
mirror of https://github.com/rustfs/rustfs.git synced 2026-09-04 19:25:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'main' into bucketmeta

Browse Source
This commit is contained in:
weisd
2024-10-09 14:36:22 +08:00
parent cc7b27325e 7cc8a5a405
commit 1b61aa135e
9 changed files with 210 additions and 277 deletions
Download Patch File Download Diff File Expand all files Collapse all files
.github/workflows/e2e.yml
+11 -7
View File
@@ -10,7 +10,7 @@ env:
jobs: jobs:
build: build:
timeout-minutes: 10 timeout-minutes: 30
runs-on: ubuntu-latest runs-on: ubuntu-latest
strategy: strategy:
matrix: matrix:
@@ -21,7 +21,7 @@ jobs:
steps: steps:
- name: cache protoc bin - name: cache protoc bin
id: cache-protoc-action id: cache-protoc-action
uses: actions/cache@v3 uses: actions/cache@v4
env: env:
cache-name: cache-protoc-action-bin cache-name: cache-protoc-action-bin
with: with:
@@ -42,7 +42,7 @@ jobs:
- name: cache flatc bin - name: cache flatc bin
id: cache-flatc-action id: cache-flatc-action
uses: actions/cache@v3 uses: actions/cache@v4
env: env:
cache-name: cache-flatc-action-bin cache-name: cache-flatc-action-bin
with: with:
@@ -65,19 +65,23 @@ jobs:
# components: rustfmt, clippy # components: rustfmt, clippy
- name: checkout - name: checkout
uses: actions/checkout@v2 uses: actions/checkout@v4
- name: run fs - name: run fs start
working-directory: .
run: |
nohup make e2e-server &
- name: run fs test
working-directory: . working-directory: .
run: | run: |
make e2e-server > /dev/null &
make probe-e2e make probe-e2e
- name: e2e test - name: e2e test
run: cargo test -p e2e_test --lib run: cargo test -p e2e_test --lib
- name: cache cargo - name: cache cargo
uses: actions/cache@v3 uses: actions/cache@v4
env: env:
cache-name: cache-cargo cache-name: cache-cargo
with: with:
.github/workflows/rust.yml
+4 -4
View File
@@ -20,7 +20,7 @@ jobs:
steps: steps:
- name: cache protoc bin - name: cache protoc bin
id: cache-protoc-action id: cache-protoc-action
uses: actions/cache@v3 uses: actions/cache@v4
env: env:
cache-name: cache-protoc-action-bin cache-name: cache-protoc-action-bin
with: with:
@@ -41,7 +41,7 @@ jobs:
- name: cache flatc bin - name: cache flatc bin
id: cache-flatc-action id: cache-flatc-action
uses: actions/cache@v3 uses: actions/cache@v4
env: env:
cache-name: cache-flatc-action-bin cache-name: cache-flatc-action-bin
with: with:
@@ -63,7 +63,7 @@ jobs:
toolchain: ${{ matrix.rust }} toolchain: ${{ matrix.rust }}
# components: rustfmt, clippy # components: rustfmt, clippy
- uses: actions/checkout@v2 - uses: actions/checkout@v4
- name: cargo build - name: cargo build
run: cargo build run: cargo build
@@ -72,7 +72,7 @@ jobs:
run: cargo test --all --exclude e2e_test run: cargo test --all --exclude e2e_test
- name: cache cargo - name: cache cargo
uses: actions/cache@v3 uses: actions/cache@v4
env: env:
cache-name: cache-cargo cache-name: cache-cargo
with: with:
Cargo.lock
Generated
+93 -146
View File
@@ -60,9 +60,9 @@ dependencies = [
[[package]] [[package]]
name = "anstyle" name = "anstyle"
version = "1.0.7" version = "1.0.8"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "038dfcf04a5feb68e9c60b21c9625a54c2c0616e79b72b0fd87075a056ae1d1b" checksum = "1bec1de6f59aedf83baf9ff929c98f2ad654b97c9510f4e70cf6f661d49fd5b1"
[[package]] [[package]]
name = "anstyle-parse" name = "anstyle-parse"
@@ -79,7 +79,7 @@ version = "1.1.0"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "ad186efb764318d35165f1758e7dcef3b10628e26d41a44bc5550652e6804391" checksum = "ad186efb764318d35165f1758e7dcef3b10628e26d41a44bc5550652e6804391"
dependencies = [ dependencies = [
"windows-sys 0.52.0", "windows-sys",
] ]
[[package]] [[package]]
@@ -89,7 +89,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "61a38449feb7068f52bb06c12759005cf459ee52bb4adc1d5a7c4322d716fb19" checksum = "61a38449feb7068f52bb06c12759005cf459ee52bb4adc1d5a7c4322d716fb19"
dependencies = [ dependencies = [
"anstyle", "anstyle",
"windows-sys 0.52.0", "windows-sys",
] ]
[[package]] [[package]]
@@ -128,9 +128,9 @@ dependencies = [
[[package]] [[package]]
name = "async-trait" name = "async-trait"
version = "0.1.80" version = "0.1.83"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "c6fa2087f2753a7da8cc1c0dbfcf89579dd57458e36769de5ac750b4671737ca" checksum = "721cae7de5c34fbb2acd27e21e6d2cf7b886dce0c27388d46c4e6c47ea4318dd"
dependencies = [ dependencies = [
"proc-macro2", "proc-macro2",
"quote", "quote",
@@ -282,9 +282,9 @@ checksum = "1fd0f2584146f6f2ef48085050886acf353beff7305ebd1ae69500e27c67f64b"
[[package]] [[package]]
name = "bytes" name = "bytes"
version = "1.6.0" version = "1.7.2"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "514de17de45fdb8dc022b1a7975556c53c86f9f0aa5f534b98977b171857c2c9" checksum = "428d9aa8fbc0670b7b8d6030a7fadd0f86151cae55e4dbbece15f3780a3dfaf3"
[[package]] [[package]]
name = "bytestring" name = "bytestring"
@@ -318,9 +318,9 @@ dependencies = [
[[package]] [[package]]
name = "clap" name = "clap"
version = "4.5.7" version = "4.5.18"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "5db83dced34638ad474f39f250d7fea9598bdd239eaced1bdf45d597da0f433f" checksum = "b0956a43b323ac1afaffc053ed5c4b7c1f1800bacd1683c353aabbb752515dd3"
dependencies = [ dependencies = [
"clap_builder", "clap_builder",
"clap_derive", "clap_derive",
@@ -328,9 +328,9 @@ dependencies = [
[[package]] [[package]]
name = "clap_builder" name = "clap_builder"
version = "4.5.7" version = "4.5.18"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "f7e204572485eb3fbf28f871612191521df159bc3e15a9f5064c66dba3a8c05f" checksum = "4d72166dd41634086d5803a47eb71ae740e61d84709c36f3c34110173db3961b"
dependencies = [ dependencies = [
"anstream", "anstream",
"anstyle", "anstyle",
@@ -340,9 +340,9 @@ dependencies = [
[[package]] [[package]]
name = "clap_derive" name = "clap_derive"
version = "4.5.5" version = "4.5.18"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "c780290ccf4fb26629baa7a1081e68ced113f1d3ec302fa5948f1c381ebf06c6" checksum = "4ac6a0c7b1a9e9a5186361f67dfa1b88213572f427fb9ab038efb2bd8c582dab"
dependencies = [ dependencies = [
"heck", "heck",
"proc-macro2", "proc-macro2",
@@ -511,7 +511,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "534c5cf6194dfab3db3242765c03bbe257cf92f22b38f6bc0c58d59108a820ba" checksum = "534c5cf6194dfab3db3242765c03bbe257cf92f22b38f6bc0c58d59108a820ba"
dependencies = [ dependencies = [
"libc", "libc",
"windows-sys 0.52.0", "windows-sys",
] ]
[[package]] [[package]]
@@ -782,9 +782,9 @@ dependencies = [
[[package]] [[package]]
name = "http-body" name = "http-body"
version = "1.0.0" 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 = "1cac85db508abc24a2e48553ba12a996e87244a0395ce011e62b37158745d643" checksum = "1efedce1fb8e6913f23e0c92de8e62cd5b772a67e7b3946df930a62566c93184"
dependencies = [ dependencies = [
"bytes", "bytes",
"http", "http",
@@ -817,9 +817,9 @@ checksum = "df3b46402a9d5adb4c86a0cf463f42e19994e3ee891101b1841f30a545cb49a9"
[[package]] [[package]]
name = "hyper" name = "hyper"
version = "1.3.1" version = "1.4.1"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "fe575dd17d0862a9a33781c8c4696a55c320909004a67a00fb286ba8b1bc496d" checksum = "50dfd22e0e76d0f662d429a5f80fcaf3855009297eab6a0a9f8543834744ba05"
dependencies = [ dependencies = [
"bytes", "bytes",
"futures-channel", "futures-channel",
@@ -851,9 +851,9 @@ dependencies = [
[[package]] [[package]]
name = "hyper-util" name = "hyper-util"
version = "0.1.5" 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 = "7b875924a60b96e5d7b9ae7b066540b1dd1cbd90d1828f54c92e02a283351c56" checksum = "41296eb09f183ac68eec06e03cdbea2e759633d4067b2f6552fc2e009bcad08b"
dependencies = [ dependencies = [
"bytes", "bytes",
"futures-channel", "futures-channel",
@@ -864,7 +864,6 @@ dependencies = [
"pin-project-lite", "pin-project-lite",
"socket2", "socket2",
"tokio", "tokio",
"tower",
"tower-service", "tower-service",
"tracing", "tracing",
] ]
@@ -1060,13 +1059,14 @@ dependencies = [
[[package]] [[package]]
name = "mio" name = "mio"
version = "0.8.11" version = "1.0.2"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "a4a650543ca06a924e8b371db273b2756685faae30f8487da1b56505a8f78b0c" checksum = "80e04d1dcff3aae0704555fe5fee3bcfaf3d1fdf8a7e521d5b9d2b42acb52cec"
dependencies = [ dependencies = [
"hermit-abi",
"libc", "libc",
"wasi", "wasi",
"windows-sys 0.48.0", "windows-sys",
] ]
[[package]] [[package]]
@@ -1352,9 +1352,9 @@ dependencies = [
[[package]] [[package]]
name = "prost" name = "prost"
version = "0.13.1" version = "0.13.3"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "e13db3d3fde688c61e2446b4d843bc27a7e8af269a69440c0308021dc92333cc" checksum = "7b0487d90e047de87f984913713b85c601c05609aad5b0df4b4573fbf69aa13f"
dependencies = [ dependencies = [
"bytes", "bytes",
"prost-derive", "prost-derive",
@@ -1383,9 +1383,9 @@ dependencies = [
[[package]] [[package]]
name = "prost-derive" name = "prost-derive"
version = "0.13.1" version = "0.13.3"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "18bec9b0adc4eba778b33684b7ba3e7137789434769ee3ce3930463ef904cfca" checksum = "e9552f850d5f0964a4e4d0bf306459ac29323ddfbae05e35a7c0d35cb0803cc5"
dependencies = [ dependencies = [
"anyhow", "anyhow",
"itertools", "itertools",
@@ -1396,18 +1396,18 @@ dependencies = [
[[package]] [[package]]
name = "prost-types" name = "prost-types"
version = "0.13.1" version = "0.13.3"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "cee5168b05f49d4b0ca581206eb14a7b22fafd963efe729ac48eb03266e25cc2" checksum = "4759aa0d3a6232fb8dbdb97b61de2c20047c68aca932c7ed76da9d788508d670"
dependencies = [ dependencies = [
"prost", "prost",
] ]
[[package]] [[package]]
name = "protobuf" name = "protobuf"
version = "3.5.1" version = "3.6.0"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "0bcc343da15609eaecd65f8aa76df8dc4209d325131d8219358c0aaaebab0bf6" checksum = "3018844a02746180074f621e847703737d27d89d7f0721a7a4da317f88b16385"
dependencies = [ dependencies = [
"once_cell", "once_cell",
"protobuf-support", "protobuf-support",
@@ -1416,9 +1416,9 @@ dependencies = [
[[package]] [[package]]
name = "protobuf-support" name = "protobuf-support"
version = "3.5.1" version = "3.6.0"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "f0766e3675a627c327e4b3964582594b0e8741305d628a98a5de75a1d15f99b9" checksum = "faf96d872914fcda2b66d66ea3fff2be7c66865d31c7bb2790cff32c0e714880"
dependencies = [ dependencies = [
"thiserror", "thiserror",
] ]
@@ -1502,6 +1502,8 @@ version = "6.0.0"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "7263373d500d4d4f505d43a2a662d475a894aa94503a1ee28e9188b5f3960d4f" checksum = "7263373d500d4d4f505d43a2a662d475a894aa94503a1ee28e9188b5f3960d4f"
dependencies = [ dependencies = [
"cc",
"libc",
"libm", "libm",
"lru", "lru",
"parking_lot", "parking_lot",
@@ -1511,14 +1513,14 @@ dependencies = [
[[package]] [[package]]
name = "regex" name = "regex"
version = "1.10.5" version = "1.11.0"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "b91213439dad192326a0d7c6ee3955910425f441d7038e0d6933b0aec5c4517f" checksum = "38200e5ee88914975b69f657f0801b6f6dccafd44fd9326302a4aaeecfacb1d8"
dependencies = [ dependencies = [
"aho-corasick", "aho-corasick",
"memchr", "memchr",
"regex-automata 0.4.7", "regex-automata 0.4.8",
"regex-syntax 0.8.4", "regex-syntax 0.8.5",
] ]
[[package]] [[package]]
@@ -1532,13 +1534,13 @@ dependencies = [
[[package]] [[package]]
name = "regex-automata" name = "regex-automata"
version = "0.4.7" version = "0.4.8"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "38caf58cc5ef2fed281f89292ef23f6365465ed9a41b7a7754eb4e26496c92df" checksum = "368758f23274712b504848e9d5a6f010445cc8b87a7cdb4d7cbee666c1288da3"
dependencies = [ dependencies = [
"aho-corasick", "aho-corasick",
"memchr", "memchr",
"regex-syntax 0.8.4", "regex-syntax 0.8.5",
] ]
[[package]] [[package]]
@@ -1549,9 +1551,9 @@ checksum = "f162c6dd7b008981e4d40210aca20b4bd0f9b60ca9271061b07f78537722f2e1"
[[package]] [[package]]
name = "regex-syntax" name = "regex-syntax"
version = "0.8.4" version = "0.8.5"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "7a66a03ae7c801facd77a29370b4faec201768915ac14a721ba36f20bc9c209b" checksum = "2b15c43186be67a4fd63bee50d0303afffcef381492ebe2c5d87f324e1b8815c"
[[package]] [[package]]
name = "ring" name = "ring"
@@ -1565,7 +1567,7 @@ dependencies = [
"libc", "libc",
"spin", "spin",
"untrusted", "untrusted",
"windows-sys 0.52.0", "windows-sys",
] ]
[[package]] [[package]]
@@ -1658,7 +1660,7 @@ dependencies = [
"errno", "errno",
"libc", "libc",
"linux-raw-sys", "linux-raw-sys",
"windows-sys 0.52.0", "windows-sys",
] ]
[[package]] [[package]]
@@ -1776,18 +1778,18 @@ checksum = "61697e0a1c7e512e84a621326239844a24d8207b4669b41bc18b32ea5cbf988b"
[[package]] [[package]]
name = "serde" name = "serde"
version = "1.0.203" version = "1.0.210"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "7253ab4de971e72fb7be983802300c30b5a7f0c2e56fab8abfc6a214307c0094" checksum = "c8e3592472072e6e22e0a54d5904d9febf8508f65fb8552499a1abc7d1078c3a"
dependencies = [ dependencies = [
"serde_derive", "serde_derive",
] ]
[[package]] [[package]]
name = "serde_derive" name = "serde_derive"
version = "1.0.203" version = "1.0.210"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "500cbc0ebeb6f46627f50f3f5811ccf6bf00643be300b4c3eabc0ef55dc5b5ba" checksum = "243902eda00fad750862fc144cea25caca5e20d615af0a81bee94ca738f1df1f"
dependencies = [ dependencies = [
"proc-macro2", "proc-macro2",
"quote", "quote",
@@ -1796,11 +1798,12 @@ dependencies = [
[[package]] [[package]]
name = "serde_json" name = "serde_json"
version = "1.0.118" version = "1.0.128"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "d947f6b3163d8857ea16c4fa0dd4840d52f3041039a85decd46867eb1abef2e4" checksum = "6ff5456707a1de34e7e37f2a6fd3d3f808c318259cbd01ab6377795054b483d8"
dependencies = [ dependencies = [
"itoa", "itoa",
"memchr",
"ryu", "ryu",
"serde", "serde",
] ]
@@ -1837,6 +1840,16 @@ dependencies = [
"cfg-if", "cfg-if",
"cpufeatures", "cpufeatures",
"digest", "digest",
"sha2-asm",
]
[[package]]
name = "sha2-asm"
version = "0.6.4"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "b845214d6175804686b2bd482bcffe96651bb2d1200742b712003504a2dac1ab"
dependencies = [
"cc",
] ]
[[package]] [[package]]
@@ -1891,7 +1904,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "ce305eb0b4296696835b71df73eb912e0f1ffd2556a501fcede6e0c50349191c" checksum = "ce305eb0b4296696835b71df73eb912e0f1ffd2556a501fcede6e0c50349191c"
dependencies = [ dependencies = [
"libc", "libc",
"windows-sys 0.52.0", "windows-sys",
] ]
[[package]] [[package]]
@@ -1945,23 +1958,23 @@ dependencies = [
"fastrand", "fastrand",
"once_cell", "once_cell",
"rustix", "rustix",
"windows-sys 0.52.0", "windows-sys",
] ]
[[package]] [[package]]
name = "thiserror" name = "thiserror"
version = "1.0.61" version = "1.0.64"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "c546c80d6be4bc6a00c0f01730c08df82eaa7a7a61f11d656526506112cc1709" checksum = "d50af8abc119fb8bb6dbabcfa89656f46f84aa0ac7688088608076ad2b459a84"
dependencies = [ dependencies = [
"thiserror-impl", "thiserror-impl",
] ]
[[package]] [[package]]
name = "thiserror-impl" name = "thiserror-impl"
version = "1.0.61" version = "1.0.64"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "46c3384250002a6d5af4d114f2845d37b57521033f30d5c3f46c4d70e1197533" checksum = "08904e7672f5eb876eaaf87e0ce17857500934f4981c4a0ab2b4aa98baac7fc3"
dependencies = [ dependencies = [
"proc-macro2", "proc-macro2",
"quote", "quote",
@@ -2026,27 +2039,26 @@ checksum = "1f3ccbac311fea05f86f61904b462b55fb3df8837a366dfc601a0161d0532f20"
[[package]] [[package]]
name = "tokio" name = "tokio"
version = "1.38.0" version = "1.40.0"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "ba4f4a02a7a80d6f274636f0aa95c7e383b912d41fe721a31f29e29698585a4a" checksum = "e2b070231665d27ad9ec9b8df639893f46727666c6767db40317fbe920a5d998"
dependencies = [ dependencies = [
"backtrace", "backtrace",
"bytes", "bytes",
"libc", "libc",
"mio", "mio",
"num_cpus",
"pin-project-lite", "pin-project-lite",
"signal-hook-registry", "signal-hook-registry",
"socket2", "socket2",
"tokio-macros", "tokio-macros",
"windows-sys 0.48.0", "windows-sys",
] ]
[[package]] [[package]]
name = "tokio-macros" name = "tokio-macros"
version = "2.3.0" version = "2.4.0"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "5f5ae998a069d4b5aba8ee9dad856af7d520c3699e6159b185c2acd48155d39a" checksum = "693d596312e88961bc67d7f1f97af8a70227d9f90c31bba5806eec004978d752"
dependencies = [ dependencies = [
"proc-macro2", "proc-macro2",
"quote", "quote",
@@ -2077,9 +2089,9 @@ dependencies = [
[[package]] [[package]]
name = "tokio-util" name = "tokio-util"
version = "0.7.11" version = "0.7.12"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "9cf6b47b3771c49ac75ad09a6162f53ad4b8088b76ac60e8ec1455b31a189fe1" checksum = "61e7c3654c13bcd040d4a03abee2c75b1d14a37b423cf5a813ceae1cc903ec6a"
dependencies = [ dependencies = [
"bytes", "bytes",
"futures-core", "futures-core",
@@ -2090,9 +2102,9 @@ dependencies = [
[[package]] [[package]]
name = "tonic" name = "tonic"
version = "0.12.1" version = "0.12.3"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "38659f4a91aba8598d27821589f5db7dddd94601e7a01b1e485a50e5484c7401" checksum = "877c5b330756d856ffcc4553ab34a5684481ade925ecc54bcd1bf02b1d0d4d52"
dependencies = [ dependencies = [
"async-stream", "async-stream",
"async-trait", "async-trait",
@@ -2123,22 +2135,23 @@ dependencies = [
[[package]] [[package]]
name = "tonic-build" name = "tonic-build"
version = "0.12.1" version = "0.12.3"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "568392c5a2bd0020723e3f387891176aabafe36fd9fcd074ad309dfa0c8eb964" checksum = "9557ce109ea773b399c9b9e5dca39294110b74f1f342cb347a80d1fce8c26a11"
dependencies = [ dependencies = [
"prettyplease", "prettyplease",
"proc-macro2", "proc-macro2",
"prost-build", "prost-build",
"prost-types",
"quote", "quote",
"syn", "syn",
] ]
[[package]] [[package]]
name = "tonic-reflection" name = "tonic-reflection"
version = "0.12.1" version = "0.12.3"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "b742c83ad673e9ab5b4ce0981f7b9e8932be9d60e8682cbf9120494764dbc173" checksum = "878d81f52e7fcfd80026b7fdb6a9b578b3c3653ba987f87f0dce4b64043cba27"
dependencies = [ dependencies = [
"prost", "prost",
"prost-types", "prost-types",
@@ -2462,37 +2475,13 @@ 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 = "712e227841d057c1ee1cd2fb22fa7e5a5461ae8e48fa2ca79ec42cfc1931183f" checksum = "712e227841d057c1ee1cd2fb22fa7e5a5461ae8e48fa2ca79ec42cfc1931183f"
[[package]]
name = "windows-sys"
version = "0.48.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "677d2418bec65e3338edb076e806bc1ec15693c5d0104683f2efe857f61056a9"
dependencies = [
"windows-targets 0.48.5",
]
[[package]] [[package]]
name = "windows-sys" name = "windows-sys"
version = "0.52.0" version = "0.52.0"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "282be5f36a8ce781fad8c8ae18fa3f9beff57ec1b52cb3de0789201425d9a33d" checksum = "282be5f36a8ce781fad8c8ae18fa3f9beff57ec1b52cb3de0789201425d9a33d"
dependencies = [ dependencies = [
"windows-targets 0.52.5", "windows-targets",
]
[[package]]
name = "windows-targets"
version = "0.48.5"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "9a2fa6e2155d7247be68c096456083145c183cbbbc2764150dda45a87197940c"
dependencies = [
"windows_aarch64_gnullvm 0.48.5",
"windows_aarch64_msvc 0.48.5",
"windows_i686_gnu 0.48.5",
"windows_i686_msvc 0.48.5",
"windows_x86_64_gnu 0.48.5",
"windows_x86_64_gnullvm 0.48.5",
"windows_x86_64_msvc 0.48.5",
] ]
[[package]] [[package]]
@@ -2501,46 +2490,28 @@ version = "0.52.5"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "6f0713a46559409d202e70e28227288446bf7841d3211583a4b53e3f6d96e7eb" checksum = "6f0713a46559409d202e70e28227288446bf7841d3211583a4b53e3f6d96e7eb"
dependencies = [ dependencies = [
"windows_aarch64_gnullvm 0.52.5", "windows_aarch64_gnullvm",
"windows_aarch64_msvc 0.52.5", "windows_aarch64_msvc",
"windows_i686_gnu 0.52.5", "windows_i686_gnu",
"windows_i686_gnullvm", "windows_i686_gnullvm",
"windows_i686_msvc 0.52.5", "windows_i686_msvc",
"windows_x86_64_gnu 0.52.5", "windows_x86_64_gnu",
"windows_x86_64_gnullvm 0.52.5", "windows_x86_64_gnullvm",
"windows_x86_64_msvc 0.52.5", "windows_x86_64_msvc",
] ]
[[package]]
name = "windows_aarch64_gnullvm"
version = "0.48.5"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "2b38e32f0abccf9987a4e3079dfb67dcd799fb61361e53e2882c3cbaf0d905d8"
[[package]] [[package]]
name = "windows_aarch64_gnullvm" name = "windows_aarch64_gnullvm"
version = "0.52.5" version = "0.52.5"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "7088eed71e8b8dda258ecc8bac5fb1153c5cffaf2578fc8ff5d61e23578d3263" checksum = "7088eed71e8b8dda258ecc8bac5fb1153c5cffaf2578fc8ff5d61e23578d3263"
[[package]]
name = "windows_aarch64_msvc"
version = "0.48.5"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "dc35310971f3b2dbbf3f0690a219f40e2d9afcf64f9ab7cc1be722937c26b4bc"
[[package]] [[package]]
name = "windows_aarch64_msvc" name = "windows_aarch64_msvc"
version = "0.52.5" version = "0.52.5"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "9985fd1504e250c615ca5f281c3f7a6da76213ebd5ccc9561496568a2752afb6" checksum = "9985fd1504e250c615ca5f281c3f7a6da76213ebd5ccc9561496568a2752afb6"
[[package]]
name = "windows_i686_gnu"
version = "0.48.5"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "a75915e7def60c94dcef72200b9a8e58e5091744960da64ec734a6c6e9b3743e"
[[package]] [[package]]
name = "windows_i686_gnu" name = "windows_i686_gnu"
version = "0.52.5" version = "0.52.5"
@@ -2553,48 +2524,24 @@ version = "0.52.5"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "87f4261229030a858f36b459e748ae97545d6f1ec60e5e0d6a3d32e0dc232ee9" checksum = "87f4261229030a858f36b459e748ae97545d6f1ec60e5e0d6a3d32e0dc232ee9"
[[package]]
name = "windows_i686_msvc"
version = "0.48.5"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "8f55c233f70c4b27f66c523580f78f1004e8b5a8b659e05a4eb49d4166cca406"
[[package]] [[package]]
name = "windows_i686_msvc" name = "windows_i686_msvc"
version = "0.52.5" version = "0.52.5"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "db3c2bf3d13d5b658be73463284eaf12830ac9a26a90c717b7f771dfe97487bf" checksum = "db3c2bf3d13d5b658be73463284eaf12830ac9a26a90c717b7f771dfe97487bf"
[[package]]
name = "windows_x86_64_gnu"
version = "0.48.5"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "53d40abd2583d23e4718fddf1ebec84dbff8381c07cae67ff7768bbf19c6718e"
[[package]] [[package]]
name = "windows_x86_64_gnu" name = "windows_x86_64_gnu"
version = "0.52.5" version = "0.52.5"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "4e4246f76bdeff09eb48875a0fd3e2af6aada79d409d33011886d3e1581517d9" checksum = "4e4246f76bdeff09eb48875a0fd3e2af6aada79d409d33011886d3e1581517d9"
[[package]]
name = "windows_x86_64_gnullvm"
version = "0.48.5"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "0b7b52767868a23d5bab768e390dc5f5c55825b6d30b86c844ff2dc7414044cc"
[[package]] [[package]]
name = "windows_x86_64_gnullvm" name = "windows_x86_64_gnullvm"
version = "0.52.5" version = "0.52.5"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "852298e482cd67c356ddd9570386e2862b5673c85bd5f88df9ab6802b334c596" checksum = "852298e482cd67c356ddd9570386e2862b5673c85bd5f88df9ab6802b334c596"
[[package]]
name = "windows_x86_64_msvc"
version = "0.48.5"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "ed94fce61571a4006852b7389a063ab983c02eb1bb37b47f8272ce92d06d9538"
[[package]] [[package]]
name = "windows_x86_64_msvc" name = "windows_x86_64_msvc"
version = "0.52.5" version = "0.52.5"
Cargo.toml
+15 -15
View File
@@ -17,39 +17,39 @@ rust-version = "1.75"
version = "0.0.1" version = "0.0.1"
[workspace.dependencies] [workspace.dependencies]
async-trait = "0.1.80" async-trait = "0.1.83"
backon = "1.2.0" backon = "1.2.0"
bytes = "1.6.0" bytes = "1.7.2"
clap = { version = "4.5.7", features = ["derive"] } clap = { version = "4.5.18", features = ["derive"] }
ecstore = { path = "./ecstore" } ecstore = { path = "./ecstore" }
flatbuffers = "24.3.25" flatbuffers = "24.3.25"
futures = "0.3.30" futures = "0.3.30"
futures-util = "0.3.30" futures-util = "0.3.30"
common = { path = "./common/common" } common = { path = "./common/common" }
hyper = "1.3.1" hyper = "1.4.1"
hyper-util = { version = "0.1.5", features = [ hyper-util = { version = "0.1.9", features = [
"tokio", "tokio",
"server-auto", "server-auto",
"server-graceful", "server-graceful",
] } ] }
http = "1.1.0" http = "1.1.0"
http-body = "1.0.0" http-body = "1.0.1"
lock = { path = "./common/lock" } lock = { path = "./common/lock" }
lazy_static = "1.5.0" lazy_static = "1.5.0"
mime = "0.3.17" mime = "0.3.17"
netif = "0.1.6" netif = "0.1.6"
pin-project-lite = "0.2" pin-project-lite = "0.2"
# pin-utils = "0.1.0" # pin-utils = "0.1.0"
prost = "0.13.1" prost = "0.13.3"
prost-build = "0.13.1" prost-build = "0.13.1"
prost-types = "0.13.1" prost-types = "0.13.3"
protobuf = "3.2" protobuf = "3.6"
protos = { path = "./common/protos" } protos = { path = "./common/protos" }
rand = "0.8.5" rand = "0.8.5"
s3s = { version = "0.10.1", default-features = true, features = ["tower"] } s3s = { version = "0.10.1", default-features = true, features = ["tower"] }
serde = { version = "1.0.203", features = ["derive"] } serde = { version = "1.0.210", features = ["derive"] }
serde_json = "1.0.117" serde_json = "1.0.128"
thiserror = "1.0.61" thiserror = "1.0.64"
time = { version = "0.3.36", features = [ time = { version = "0.3.36", features = [
"std", "std",
"parsing", "parsing",
@@ -57,9 +57,9 @@ time = { version = "0.3.36", features = [
"macros", "macros",
"serde", "serde",
] } ] }
tokio = { version = "1.38.0", features = ["fs", "rt-multi-thread"] } tokio = { version = "1.40.0", features = ["fs", "rt-multi-thread"] }
tonic = { version = "0.12.1", features = ["gzip"] } tonic = { version = "0.12.3", features = ["gzip"] }
tonic-build = "0.12.1" tonic-build = "0.12.3"
tonic-reflection = "0.12" tonic-reflection = "0.12"
tokio-stream = "0.1.16" tokio-stream = "0.1.16"
tower = { version = "0.4.13", features = ["timeout"] } tower = { version = "0.4.13", features = ["timeout"] }
common/protos/src/generated/proto_gen/node_service.rs
+77 -96
View File
@@ -580,7 +580,13 @@ pub struct GenerallyLockResponse {
} }
/// Generated client implementations. /// Generated client implementations.
pub mod node_service_client { pub mod node_service_client {
#![allow(unused_variables, dead_code, missing_docs, clippy::let_unit_value)] #![allow(
unused_variables,
dead_code,
missing_docs,
clippy::wildcard_imports,
clippy::let_unit_value,
)]
use tonic::codegen::*; use tonic::codegen::*;
use tonic::codegen::http::Uri; use tonic::codegen::http::Uri;
#[derive(Debug, Clone)] #[derive(Debug, Clone)]
@@ -602,8 +608,8 @@ pub mod node_service_client {
where where
T: tonic::client::GrpcService<tonic::body::BoxBody>, T: tonic::client::GrpcService<tonic::body::BoxBody>,
T::Error: Into<StdError>, T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + Send + 'static, T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + Send, <T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
{ {
pub fn new(inner: T) -> Self { pub fn new(inner: T) -> Self {
let inner = tonic::client::Grpc::new(inner); let inner = tonic::client::Grpc::new(inner);
@@ -628,7 +634,7 @@ pub mod node_service_client {
>, >,
<T as tonic::codegen::Service< <T as tonic::codegen::Service<
http::Request<tonic::body::BoxBody>, http::Request<tonic::body::BoxBody>,
>>::Error: Into<StdError> + Send + Sync, >>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
{ {
NodeServiceClient::new(InterceptedService::new(inner, interceptor)) NodeServiceClient::new(InterceptedService::new(inner, interceptor))
} }
@@ -672,8 +678,7 @@ pub mod node_service_client {
.ready() .ready()
.await .await
.map_err(|e| { .map_err(|e| {
tonic::Status::new( tonic::Status::unknown(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
@@ -697,8 +702,7 @@ pub mod node_service_client {
.ready() .ready()
.await .await
.map_err(|e| { .map_err(|e| {
tonic::Status::new( tonic::Status::unknown(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
@@ -722,8 +726,7 @@ pub mod node_service_client {
.ready() .ready()
.await .await
.map_err(|e| { .map_err(|e| {
tonic::Status::new( tonic::Status::unknown(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
@@ -747,8 +750,7 @@ pub mod node_service_client {
.ready() .ready()
.await .await
.map_err(|e| { .map_err(|e| {
tonic::Status::new( tonic::Status::unknown(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
@@ -772,8 +774,7 @@ pub mod node_service_client {
.ready() .ready()
.await .await
.map_err(|e| { .map_err(|e| {
tonic::Status::new( tonic::Status::unknown(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
@@ -797,8 +798,7 @@ pub mod node_service_client {
.ready() .ready()
.await .await
.map_err(|e| { .map_err(|e| {
tonic::Status::new( tonic::Status::unknown(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
@@ -822,8 +822,7 @@ pub mod node_service_client {
.ready() .ready()
.await .await
.map_err(|e| { .map_err(|e| {
tonic::Status::new( tonic::Status::unknown(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
@@ -844,8 +843,7 @@ pub mod node_service_client {
.ready() .ready()
.await .await
.map_err(|e| { .map_err(|e| {
tonic::Status::new( tonic::Status::unknown(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
@@ -869,8 +867,7 @@ pub mod node_service_client {
.ready() .ready()
.await .await
.map_err(|e| { .map_err(|e| {
tonic::Status::new( tonic::Status::unknown(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
@@ -894,8 +891,7 @@ pub mod node_service_client {
.ready() .ready()
.await .await
.map_err(|e| { .map_err(|e| {
tonic::Status::new( tonic::Status::unknown(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
@@ -916,8 +912,7 @@ pub mod node_service_client {
.ready() .ready()
.await .await
.map_err(|e| { .map_err(|e| {
tonic::Status::new( tonic::Status::unknown(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
@@ -941,8 +936,7 @@ pub mod node_service_client {
.ready() .ready()
.await .await
.map_err(|e| { .map_err(|e| {
tonic::Status::new( tonic::Status::unknown(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
@@ -967,8 +961,7 @@ pub mod node_service_client {
.ready() .ready()
.await .await
.map_err(|e| { .map_err(|e| {
tonic::Status::new( tonic::Status::unknown(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
@@ -992,8 +985,7 @@ pub mod node_service_client {
.ready() .ready()
.await .await
.map_err(|e| { .map_err(|e| {
tonic::Status::new( tonic::Status::unknown(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
@@ -1017,8 +1009,7 @@ pub mod node_service_client {
.ready() .ready()
.await .await
.map_err(|e| { .map_err(|e| {
tonic::Status::new( tonic::Status::unknown(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
@@ -1042,8 +1033,7 @@ pub mod node_service_client {
.ready() .ready()
.await .await
.map_err(|e| { .map_err(|e| {
tonic::Status::new( tonic::Status::unknown(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
@@ -1067,8 +1057,7 @@ pub mod node_service_client {
.ready() .ready()
.await .await
.map_err(|e| { .map_err(|e| {
tonic::Status::new( tonic::Status::unknown(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
@@ -1092,8 +1081,7 @@ pub mod node_service_client {
.ready() .ready()
.await .await
.map_err(|e| { .map_err(|e| {
tonic::Status::new( tonic::Status::unknown(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
@@ -1117,8 +1105,7 @@ pub mod node_service_client {
.ready() .ready()
.await .await
.map_err(|e| { .map_err(|e| {
tonic::Status::new( tonic::Status::unknown(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
@@ -1142,8 +1129,7 @@ pub mod node_service_client {
.ready() .ready()
.await .await
.map_err(|e| { .map_err(|e| {
tonic::Status::new( tonic::Status::unknown(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
@@ -1167,8 +1153,7 @@ pub mod node_service_client {
.ready() .ready()
.await .await
.map_err(|e| { .map_err(|e| {
tonic::Status::new( tonic::Status::unknown(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
@@ -1192,8 +1177,7 @@ pub mod node_service_client {
.ready() .ready()
.await .await
.map_err(|e| { .map_err(|e| {
tonic::Status::new( tonic::Status::unknown(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
@@ -1217,8 +1201,7 @@ pub mod node_service_client {
.ready() .ready()
.await .await
.map_err(|e| { .map_err(|e| {
tonic::Status::new( tonic::Status::unknown(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
@@ -1242,8 +1225,7 @@ pub mod node_service_client {
.ready() .ready()
.await .await
.map_err(|e| { .map_err(|e| {
tonic::Status::new( tonic::Status::unknown(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
@@ -1264,8 +1246,7 @@ pub mod node_service_client {
.ready() .ready()
.await .await
.map_err(|e| { .map_err(|e| {
tonic::Status::new( tonic::Status::unknown(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
@@ -1289,8 +1270,7 @@ pub mod node_service_client {
.ready() .ready()
.await .await
.map_err(|e| { .map_err(|e| {
tonic::Status::new( tonic::Status::unknown(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
@@ -1314,8 +1294,7 @@ pub mod node_service_client {
.ready() .ready()
.await .await
.map_err(|e| { .map_err(|e| {
tonic::Status::new( tonic::Status::unknown(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
@@ -1339,8 +1318,7 @@ pub mod node_service_client {
.ready() .ready()
.await .await
.map_err(|e| { .map_err(|e| {
tonic::Status::new( tonic::Status::unknown(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
@@ -1364,8 +1342,7 @@ pub mod node_service_client {
.ready() .ready()
.await .await
.map_err(|e| { .map_err(|e| {
tonic::Status::new( tonic::Status::unknown(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
@@ -1389,8 +1366,7 @@ pub mod node_service_client {
.ready() .ready()
.await .await
.map_err(|e| { .map_err(|e| {
tonic::Status::new( tonic::Status::unknown(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
@@ -1414,8 +1390,7 @@ pub mod node_service_client {
.ready() .ready()
.await .await
.map_err(|e| { .map_err(|e| {
tonic::Status::new( tonic::Status::unknown(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
@@ -1439,8 +1414,7 @@ pub mod node_service_client {
.ready() .ready()
.await .await
.map_err(|e| { .map_err(|e| {
tonic::Status::new( tonic::Status::unknown(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
@@ -1464,8 +1438,7 @@ pub mod node_service_client {
.ready() .ready()
.await .await
.map_err(|e| { .map_err(|e| {
tonic::Status::new( tonic::Status::unknown(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
@@ -1489,8 +1462,7 @@ pub mod node_service_client {
.ready() .ready()
.await .await
.map_err(|e| { .map_err(|e| {
tonic::Status::new( tonic::Status::unknown(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
@@ -1514,8 +1486,7 @@ pub mod node_service_client {
.ready() .ready()
.await .await
.map_err(|e| { .map_err(|e| {
tonic::Status::new( tonic::Status::unknown(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()), format!("Service was not ready: {}", e.into()),
) )
})?; })?;
@@ -1532,11 +1503,17 @@ pub mod node_service_client {
} }
/// Generated server implementations. /// Generated server implementations.
pub mod node_service_server { pub mod node_service_server {
#![allow(unused_variables, dead_code, missing_docs, clippy::let_unit_value)] #![allow(
unused_variables,
dead_code,
missing_docs,
clippy::wildcard_imports,
clippy::let_unit_value,
)]
use tonic::codegen::*; use tonic::codegen::*;
/// Generated trait containing gRPC methods that should be implemented for use with NodeServiceServer. /// Generated trait containing gRPC methods that should be implemented for use with NodeServiceServer.
#[async_trait] #[async_trait]
pub trait NodeService: Send + Sync + 'static { pub trait NodeService: std::marker::Send + std::marker::Sync + 'static {
/// -------------------------------meta service-------------------------- /// -------------------------------meta service--------------------------
async fn ping( async fn ping(
&self, &self,
@@ -1607,7 +1584,7 @@ pub mod node_service_server {
type WriteStreamStream: tonic::codegen::tokio_stream::Stream< type WriteStreamStream: tonic::codegen::tokio_stream::Stream<
Item = std::result::Result<super::WriteResponse, tonic::Status>, Item = std::result::Result<super::WriteResponse, tonic::Status>,
> >
+ Send + std::marker::Send
+ 'static; + 'static;
async fn write_stream( async fn write_stream(
&self, &self,
@@ -1620,7 +1597,7 @@ pub mod node_service_server {
type ReadAtStream: tonic::codegen::tokio_stream::Stream< type ReadAtStream: tonic::codegen::tokio_stream::Stream<
Item = std::result::Result<super::ReadAtResponse, tonic::Status>, Item = std::result::Result<super::ReadAtResponse, tonic::Status>,
> >
+ Send + std::marker::Send
+ 'static; + 'static;
/// rpc Append(AppendRequest) returns (AppendResponse) {}; /// rpc Append(AppendRequest) returns (AppendResponse) {};
async fn read_at( async fn read_at(
@@ -1774,14 +1751,14 @@ pub mod node_service_server {
>; >;
} }
#[derive(Debug)] #[derive(Debug)]
pub struct NodeServiceServer<T: NodeService> { pub struct NodeServiceServer<T> {
inner: Arc<T>, inner: Arc<T>,
accept_compression_encodings: EnabledCompressionEncodings, accept_compression_encodings: EnabledCompressionEncodings,
send_compression_encodings: EnabledCompressionEncodings, send_compression_encodings: EnabledCompressionEncodings,
max_decoding_message_size: Option<usize>, max_decoding_message_size: Option<usize>,
max_encoding_message_size: Option<usize>, max_encoding_message_size: Option<usize>,
} }
impl<T: NodeService> NodeServiceServer<T> { impl<T> NodeServiceServer<T> {
pub fn new(inner: T) -> Self { pub fn new(inner: T) -> Self {
Self::from_arc(Arc::new(inner)) Self::from_arc(Arc::new(inner))
} }
@@ -1835,8 +1812,8 @@ pub mod node_service_server {
impl<T, B> tonic::codegen::Service<http::Request<B>> for NodeServiceServer<T> impl<T, B> tonic::codegen::Service<http::Request<B>> for NodeServiceServer<T>
where where
T: NodeService, T: NodeService,
B: Body + Send + 'static, B: Body + std::marker::Send + 'static,
B::Error: Into<StdError> + Send + 'static, B::Error: Into<StdError> + std::marker::Send + 'static,
{ {
type Response = http::Response<tonic::body::BoxBody>; type Response = http::Response<tonic::body::BoxBody>;
type Error = std::convert::Infallible; type Error = std::convert::Infallible;
@@ -3428,23 +3405,25 @@ pub mod node_service_server {
} }
_ => { _ => {
Box::pin(async move { Box::pin(async move {
Ok( let mut response = http::Response::new(empty_body());
http::Response::builder() let headers = response.headers_mut();
.status(200) headers
.header("grpc-status", tonic::Code::Unimplemented as i32) .insert(
.header( tonic::Status::GRPC_STATUS,
http::header::CONTENT_TYPE, (tonic::Code::Unimplemented as i32).into(),
tonic::metadata::GRPC_CONTENT_TYPE, );
) headers
.body(empty_body()) .insert(
.unwrap(), http::header::CONTENT_TYPE,
) tonic::metadata::GRPC_CONTENT_TYPE,
);
Ok(response)
}) })
} }
} }
} }
} }
impl<T: NodeService> Clone for NodeServiceServer<T> { impl<T> Clone for NodeServiceServer<T> {
fn clone(&self) -> Self { fn clone(&self) -> Self {
let inner = self.inner.clone(); let inner = self.inner.clone();
Self { Self {
@@ -3456,7 +3435,9 @@ pub mod node_service_server {
} }
} }
} }
impl<T: NodeService> tonic::server::NamedService for NodeServiceServer<T> { /// Generated gRPC service name
const NAME: &'static str = "node_service.NodeService"; pub const SERVICE_NAME: &str = "node_service.NodeService";
impl<T> tonic::server::NamedService for NodeServiceServer<T> {
const NAME: &'static str = SERVICE_NAME;
} }
} }
e2e_test/Cargo.toml
+1 -1
View File
@@ -15,7 +15,7 @@ lazy_static.workspace = true
lock.workspace = true lock.workspace = true
protos.workspace = true protos.workspace = true
serde_json.workspace = true serde_json.workspace = true
tonic = { version = "0.12.1", features = ["gzip"] } tonic = { version = "0.12.3", features = ["gzip"] }
tokio = { workspace = true } tokio = { workspace = true }
tower.workspace = true tower.workspace = true
url.workspace = true url.workspace = true
ecstore/Cargo.toml
+4 -4
View File
@@ -23,21 +23,21 @@ tracing-error.workspace = true
http.workspace = true http.workspace = true
url.workspace = true url.workspace = true
uuid = { version = "1.8.0", features = ["v4", "fast-rng", "serde"] } uuid = { version = "1.8.0", features = ["v4", "fast-rng", "serde"] }
reed-solomon-erasure = "6.0.0" reed-solomon-erasure = { version = "6.0.0", features = [ "simd-accel" ] }
transform-stream = "0.3.0" transform-stream = "0.3.0"
lazy_static.workspace = true lazy_static.workspace = true
lock.workspace = true lock.workspace = true
regex = "1.10.5" regex = "1.11.0"
netif = "0.1.6" netif = "0.1.6"
path-absolutize = "3.1.1" path-absolutize = "3.1.1"
protos.workspace = true protos.workspace = true
rmp-serde = "1.3.0" rmp-serde = "1.3.0"
tokio-util = { version = "0.7.11", features = ["io"] } tokio-util = { version = "0.7.12", features = ["io"] }
s3s = "0.10.0" s3s = "0.10.0"
crc32fast = "1.4.2" crc32fast = "1.4.2"
siphasher = "1.0.1" siphasher = "1.0.1"
base64-simd = "0.8.0" base64-simd = "0.8.0"
sha2 = "0.10.8" sha2 = { version = "0.10.8", features = ["asm"] }
hex-simd = "0.8.0" hex-simd = "0.8.0"
path-clean = "1.0.1" path-clean = "1.0.1"
tokio = { workspace = true, features = ["io-util", "sync"] } tokio = { workspace = true, features = ["io-util", "sync"] }
rustfs/Cargo.toml
+3 -3
View File
@@ -42,7 +42,7 @@ tokio = { workspace = true, features = [
"signal", "signal",
] } ] }
tokio-stream.workspace = true tokio-stream.workspace = true
tonic = { version = "0.12.1", features = ["gzip"] } tonic = { version = "0.12.3", features = ["gzip"] }
tonic-reflection.workspace = true tonic-reflection.workspace = true
tower.workspace = true tower.workspace = true
tracing-error.workspace = true tracing-error.workspace = true
@@ -60,9 +60,9 @@ futures-util.workspace = true
# uuid = { version = "1.8.0", features = ["v4", "fast-rng", "serde"] } # uuid = { version = "1.8.0", features = ["v4", "fast-rng", "serde"] }
ecstore = { path = "../ecstore" } ecstore = { path = "../ecstore" }
s3s = "0.10.0" s3s = "0.10.0"
clap = { version = "4.5.7", features = ["derive"] } clap = { version = "4.5.18", features = ["derive"] }
tracing-subscriber = { version = "0.3.18", features = ["env-filter", "time"] } tracing-subscriber = { version = "0.3.18", features = ["env-filter", "time"] }
hyper-util = { version = "0.1.5", features = [ hyper-util = { version = "0.1.9", features = [
"tokio", "tokio",
"server-auto", "server-auto",
"server-graceful", "server-graceful",
scripts/run.sh
+2 -1
View File
@@ -24,4 +24,5 @@ fi
# --domain-name 127.0.0.1:9010 \ # --domain-name 127.0.0.1:9010 \
# "$DATA_DIR_ARG" # "$DATA_DIR_ARG"
cargo run "$DATA_DIR_ARG" # cargo run "$DATA_DIR_ARG"
cargo run ./target/volume/test