diff --git a/.docker/Dockerfile.devenv b/.docker/Dockerfile.devenv
index e95027d2..de2fcb49 100644
--- a/.docker/Dockerfile.devenv
+++ b/.docker/Dockerfile.devenv
@@ -4,7 +4,7 @@ ENV LANG C.UTF-8
RUN sed -i s@http://.*archive.ubuntu.com@http://repo.huaweicloud.com@g /etc/apt/sources.list
-RUN apt-get clean && apt-get update && apt-get install wget git curl unzip gcc pkg-config libssl-dev -y
+RUN apt-get clean && apt-get update && apt-get install wget git curl unzip gcc pkg-config libssl-dev lld libdbus-1-dev libwayland-dev libwebkit2gtk-4.1-dev libxdo-dev -y
# install protoc
RUN wget https://github.com/protocolbuffers/protobuf/releases/download/v27.0/protoc-27.0-linux-x86_64.zip \
diff --git a/.docker/Dockerfile.ubuntu22.04 b/.docker/Dockerfile.ubuntu22.04
index 546b16b7..b955de8e 100644
--- a/.docker/Dockerfile.ubuntu22.04
+++ b/.docker/Dockerfile.ubuntu22.04
@@ -4,7 +4,7 @@ ENV LANG C.UTF-8
RUN sed -i s@http://.*archive.ubuntu.com@http://repo.huaweicloud.com@g /etc/apt/sources.list
-RUN apt-get clean && apt-get update && apt-get install wget git curl unzip gcc pkg-config libssl-dev -y
+RUN apt-get clean && apt-get update && apt-get install wget git curl unzip gcc pkg-config libssl-dev lld libdbus-1-dev libwayland-dev libwebkit2gtk-4.1-dev libxdo-dev -y
# install protoc
RUN wget https://github.com/protocolbuffers/protobuf/releases/download/v27.0/protoc-27.0-linux-x86_64.zip \
diff --git a/Cargo.lock b/Cargo.lock
index b6bba26a..b5722b5c 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -17,21 +17,6 @@ version = "2.0.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "512761e0bb2578dd7380c6baaa0f4ce03e84f95e960231d1dec8bf4d7d6e2627"
-[[package]]
-name = "admin"
-version = "0.0.1"
-dependencies = [
- "axum",
- "ecstore",
- "futures-util",
- "hyper",
- "mime",
- "serde",
- "serde_json",
- "time",
- "tower 0.5.2",
-]
-
[[package]]
name = "aead"
version = "0.5.2"
@@ -1960,6 +1945,7 @@ dependencies = [
"tracing-error",
"transform-stream",
"url",
+ "urlencoding",
"uuid",
"winapi",
"workers",
@@ -5309,7 +5295,6 @@ dependencies = [
name = "rustfs"
version = "0.1.0"
dependencies = [
- "admin",
"async-trait",
"atoi",
"axum",
diff --git a/Cargo.toml b/Cargo.toml
index 01e4a072..a78ec0d7 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -7,7 +7,6 @@ members = [
"common/common", # Shared utilities and data structures
"common/lock", # Distributed locking implementation
"common/protos", # Protocol buffer definitions
- "api/admin", # Admin HTTP API endpoints
"reader", # Object reading service
"common/workers", # Worker thread pools and task scheduling
"iam", # Identity and Access Management
diff --git a/Makefile b/Makefile
index b3b2e83a..94dd8853 100644
--- a/Makefile
+++ b/Makefile
@@ -37,9 +37,9 @@ probe-e2e:
# in target/rockylinux9.3/release/rustfs
BUILD_OS ?= rockylinux9.3
.PHONY: build
-build: ROCKYLINUX_BUILD_IMAGE_NAME = $(BUILD_OS):v1
+build: ROCKYLINUX_BUILD_IMAGE_NAME = rustfs-$(BUILD_OS):v1
build: ROCKYLINUX_BUILD_CONTAINER_NAME = rustfs-$(BUILD_OS)-build
-build: BUILD_CMD = /root/.cargo/bin/cargo build --release --target-dir /root/s3-rustfs/target/$(BUILD_OS)
+build: BUILD_CMD = /root/.cargo/bin/cargo build --release --bin rustfs --target-dir /root/s3-rustfs/target/$(BUILD_OS)
build:
$(DOCKER_CLI) build -t $(ROCKYLINUX_BUILD_IMAGE_NAME) -f $(DOCKERFILE_PATH)/Dockerfile.$(BUILD_OS) .
$(DOCKER_CLI) run --rm --name $(ROCKYLINUX_BUILD_CONTAINER_NAME) -v $(shell pwd):/root/s3-rustfs -it $(ROCKYLINUX_BUILD_IMAGE_NAME) $(BUILD_CMD)
diff --git a/TODO.md b/TODO.md
index 2aa1ca64..597a00f4 100644
--- a/TODO.md
+++ b/TODO.md
@@ -57,3 +57,41 @@
- [ ] 对象压缩
- [ ] STS
- [ ] 分层(阿里云、腾讯云、S3远程对接)
+
+
+
+scp ./target/ubuntu22.04/release/rustfs.zip root@8.130.183.154:~/
+scp ./target/ubuntu22.04/release/rustfs.zip root@8.130.177.182:~/
+scp ./target/ubuntu22.04/release/rustfs.zip root@8.130.91.189:~/
+scp ./target/ubuntu22.04/release/rustfs.zip root@8.130.182.114:~/
+
+scp ./target/x86_64-unknown-linux-musl/release/rustfs root@8.130.183.154:~/
+scp ./target/x86_64-unknown-linux-musl/release/rustfs root@8.130.177.182:~/
+scp ./target/x86_64-unknown-linux-musl/release/rustfs root@8.130.91.189:~/
+scp ./target/x86_64-unknown-linux-musl/release/rustfs root@8.130.182.114:~/
+
+
+
+
+
+ 2025-03-11T06:18:50.011565Z DEBUG s3s::service: req: Request { method: PUT, uri: /rustfs/rpc/put_file_stream?disk=http://node2:9000/data/rustfs2&volume=.rustfs.sys/tmp&path=a45ade1a-e09b-4eb4-bac1-8b5f55f7d438/235da61f-a705-4f9a-aa21-7801d2eaf61d/part.1&append=false, version: HTTP/1.1, headers: {"accept": "*/*", "host": "node2:9000", "transfer-encoding": "chunked"}, body: Body { hyper: Body(Streaming) } }
+ at /Users/weisd/.cargo/git/checkouts/s3s-58426f2d17c34859/ab139f7/crates/s3s/src/service.rs:81
+ in s3s::service::call with start_time: 2025-03-11 6:18:50.011550933 +00:00:00
+
+ 2025-03-11T06:18:50.011603Z DEBUG s3s::ops: parsing path-style request, decoded_uri_path: "/rustfs/rpc/put_file_stream"
+ at /Users/weisd/.cargo/git/checkouts/s3s-58426f2d17c34859/ab139f7/crates/s3s/src/ops/mod.rs:266
+ in s3s::service::call with start_time: 2025-03-11 6:18:50.011550933 +00:00:00
+
+ 2025-03-11T06:18:50.011651Z DEBUG s3s::ops: body_changed: false, decoded_content_length: None, has_multipart: false
+ at /Users/weisd/.cargo/git/checkouts/s3s-58426f2d17c34859/ab139f7/crates/s3s/src/ops/mod.rs:342
+ in s3s::service::call with start_time: 2025-03-11 6:18:50.011550933 +00:00:00
+
+ 2025-03-11T06:18:50.011687Z WARN rustfs::admin::rpc: handle PutFile
+ at rustfs/src/admin/rpc.rs:120
+ in s3s::service::call with start_time: 2025-03-11 6:18:50.011550933 +00:00:00
+
+ 2025-03-11T06:18:50.011716Z DEBUG s3s::ops: custom route returns error, err: S3Error(Inner { code: InvalidArgument, message: Some("get query failed1 Error(\"missing field `size`\")"), request_id: None, status_code: None, source: None, headers: None })
+ at /Users/weisd/.cargo/git/checkouts/s3s-58426f2d17c34859/ab139f7/crates/s3s/src/ops/mod.rs:227
+ in s3s::service::call with start_time: 2025-03-11 6:18:50.011550933 +00:00:00
+
+ 2025-03-11T06:18:50.011751Z DEBUG s3s::service: res: Response { status: 400, version: HTTP/1.1, headers: {"content-type": "application/xml"}, body: Body { once: b"InvalidArgumentget query failed1 Error("missing field `size`")" } }
\ No newline at end of file
diff --git a/api/admin/Cargo.toml b/api/admin/Cargo.toml
deleted file mode 100644
index 7c86092c..00000000
--- a/api/admin/Cargo.toml
+++ /dev/null
@@ -1,21 +0,0 @@
-[package]
-name = "admin"
-edition.workspace = true
-license.workspace = true
-repository.workspace = true
-rust-version.workspace = true
-version.workspace = true
-
-[lints]
-workspace = true
-
-[dependencies]
-axum.workspace = true
-mime.workspace = true
-serde.workspace = true
-serde_json.workspace = true
-ecstore = { path = "../../ecstore" }
-time = { workspace = true, features = ["serde"] }
-tower.workspace = true
-futures-util = "0.3.31"
-hyper.workspace = true
diff --git a/api/admin/src/error.rs b/api/admin/src/error.rs
deleted file mode 100644
index bbe24460..00000000
--- a/api/admin/src/error.rs
+++ /dev/null
@@ -1,98 +0,0 @@
-use axum::{
- body::Body,
- http::{header::CONTENT_TYPE, HeaderValue, StatusCode},
- response::{IntoResponse, Response},
-};
-use mime::APPLICATION_JSON;
-use serde::Serialize;
-
-#[derive(Serialize, Default)]
-#[serde(rename_all = "PascalCase")]
-pub struct ErrorResponse {
- pub code: String,
- pub message: String,
- #[serde(skip_serializing_if = "Option::is_none")]
- pub key: Option,
- #[serde(skip_serializing_if = "Option::is_none")]
- pub bucket_name: Option,
- pub resource: String,
- #[serde(skip_serializing_if = "Option::is_none")]
- pub region: Option,
- #[serde(skip_serializing_if = "Option::is_none")]
- pub request_id: Option,
- pub host_id: String,
- #[serde(skip_serializing_if = "Option::is_none")]
- pub actual_object_size: Option,
- #[serde(skip_serializing_if = "Option::is_none")]
- pub range_requested: Option,
-}
-
-impl IntoResponse for APIError {
- fn into_response(self) -> Response {
- let code = self.http_status_code;
- let err_response = ErrorResponse::from(self);
- let json_res = match serde_json::to_vec(&err_response) {
- Ok(r) => r,
- Err(e) => return (StatusCode::INTERNAL_SERVER_ERROR, format!("{e}")).into_response(),
- };
-
- Response::builder()
- .status(code)
- .header(CONTENT_TYPE, HeaderValue::from_static(APPLICATION_JSON.as_ref()))
- .body(Body::from(json_res))
- .unwrap_or_else(|e| (StatusCode::INTERNAL_SERVER_ERROR, format!("{e}")).into_response())
- }
-}
-
-#[derive(Default)]
-pub struct APIError {
- code: String,
- description: String,
- http_status_code: StatusCode,
- object_size: Option,
- range_requested: Option,
-}
-
-pub enum ErrorCode {
- ErrNotImplemented,
- ErrServerNotInitialized,
-}
-
-impl IntoResponse for ErrorCode {
- fn into_response(self) -> Response {
- APIError::from(self).into_response()
- }
-}
-
-impl From for APIError {
- fn from(value: ErrorCode) -> Self {
- use ErrorCode::*;
-
- match value {
- ErrNotImplemented => APIError {
- code: "NotImplemented".into(),
- description: "A header you provided implies functionality that is not implemented.".into(),
- http_status_code: StatusCode::NOT_IMPLEMENTED,
- ..Default::default()
- },
- ErrServerNotInitialized => APIError {
- code: "ServerNotInitialized".into(),
- description: "Server not initialized yet, please try again.".into(),
- http_status_code: StatusCode::SERVICE_UNAVAILABLE,
- ..Default::default()
- },
- }
- }
-}
-
-impl From for ErrorResponse {
- fn from(value: APIError) -> Self {
- Self {
- code: value.code,
- message: value.description,
- actual_object_size: value.object_size,
- range_requested: value.range_requested,
- ..Default::default()
- }
- }
-}
diff --git a/api/admin/src/handlers.rs b/api/admin/src/handlers.rs
deleted file mode 100644
index fa5c33dd..00000000
--- a/api/admin/src/handlers.rs
+++ /dev/null
@@ -1 +0,0 @@
-pub mod list_pools;
diff --git a/api/admin/src/handlers/list_pools.rs b/api/admin/src/handlers/list_pools.rs
deleted file mode 100644
index b80dd465..00000000
--- a/api/admin/src/handlers/list_pools.rs
+++ /dev/null
@@ -1,83 +0,0 @@
-use crate::error::ErrorCode;
-use crate::Result as LocalResult;
-
-use axum::Json;
-use ecstore::new_object_layer_fn;
-use serde::Serialize;
-use time::OffsetDateTime;
-
-#[derive(Serialize)]
-pub struct PoolStatus {
- id: i64,
- cmdline: String,
- #[serde(rename = "lastUpdate")]
- #[serde(serialize_with = "time::serde::rfc3339::serialize")]
- last_updat: OffsetDateTime,
- #[serde(skip_serializing_if = "Option::is_none")]
- #[serde(rename = "decommissionInfo")]
- decommission_info: Option,
-}
-
-#[derive(Serialize)]
-#[serde(rename_all = "camelCase")]
-struct PoolDecommissionInfo {
- #[serde(serialize_with = "time::serde::rfc3339::serialize")]
- start_time: OffsetDateTime,
- start_size: i64,
- total_size: i64,
- current_size: i64,
- complete: bool,
- failed: bool,
- canceled: bool,
-
- #[serde(rename = "objectsDecommissioned")]
- items_decommissioned: i64,
- #[serde(rename = "objectsDecommissionedFailed")]
- items_decommission_failed: i64,
- #[serde(rename = "bytesDecommissioned")]
- bytes_done: i64,
- #[serde(rename = "bytesDecommissionedFailed")]
- bytes_failed: i64,
-}
-
-pub async fn handler() -> LocalResult>> {
- // if ecstore::is_legacy().await {
- // return Err(ErrorCode::ErrNotImplemented);
- // }
- //
- //
-
- // todo 实用oncelock作为全局变量
-
- let Some(store) = new_object_layer_fn() else { return Err(ErrorCode::ErrNotImplemented) };
- // todo, 调用pool.status()接口获取每个池的数据
- //
- let mut result = Vec::new();
- for (idx, _pool) in store.pools.iter().enumerate() {
- // 这里mock一下数据
- result.push(PoolStatus {
- id: idx as _,
- cmdline: "cmdline".into(),
- last_updat: OffsetDateTime::now_utc(),
- decommission_info: if idx % 2 == 0 {
- Some(PoolDecommissionInfo {
- start_time: OffsetDateTime::now_utc(),
- start_size: 1,
- total_size: 2,
- current_size: 2,
- complete: true,
- failed: true,
- canceled: true,
- items_decommissioned: 1,
- items_decommission_failed: 1,
- bytes_done: 1,
- bytes_failed: 1,
- })
- } else {
- None
- },
- })
- }
-
- Ok(Json(result))
-}
diff --git a/api/admin/src/lib.rs b/api/admin/src/lib.rs
deleted file mode 100644
index a0477dfd..00000000
--- a/api/admin/src/lib.rs
+++ /dev/null
@@ -1,20 +0,0 @@
-pub mod error;
-pub mod handlers;
-
-use axum::{extract::Request, response::Response, routing::get, BoxError, Router};
-use error::ErrorCode;
-use handlers::list_pools;
-use tower::Service;
-
-pub type Result = std::result::Result;
-
-const API_VERSION: &str = "/v3";
-
-pub fn register_admin_router() -> impl Service, Future: Send> + Clone {
- Router::new()
- .nest(
- "/rustfs/admin",
- Router::new().nest(API_VERSION, Router::new().route("/pools/list", get(list_pools::handler))),
- )
- .into_service()
-}
diff --git a/api/admin/src/middlewares.rs b/api/admin/src/middlewares.rs
deleted file mode 100644
index e69de29b..00000000
diff --git a/common/protos/src/generated/flatbuffers_generated/models.rs b/common/protos/src/generated/flatbuffers_generated/models.rs
index e4949fdc..aa1f6ae2 100644
--- a/common/protos/src/generated/flatbuffers_generated/models.rs
+++ b/common/protos/src/generated/flatbuffers_generated/models.rs
@@ -1,9 +1,10 @@
// automatically generated by the FlatBuffers compiler, do not modify
+
// @generated
-use core::cmp::Ordering;
use core::mem;
+use core::cmp::Ordering;
extern crate flatbuffers;
use self::flatbuffers::{EndianScalar, Follow};
@@ -11,114 +12,112 @@ use self::flatbuffers::{EndianScalar, Follow};
#[allow(unused_imports, dead_code)]
pub mod models {
- use core::cmp::Ordering;
- use core::mem;
+ use core::mem;
+ use core::cmp::Ordering;
- extern crate flatbuffers;
- use self::flatbuffers::{EndianScalar, Follow};
+ extern crate flatbuffers;
+ use self::flatbuffers::{EndianScalar, Follow};
- pub enum PingBodyOffset {}
- #[derive(Copy, Clone, PartialEq)]
+pub enum PingBodyOffset {}
+#[derive(Copy, Clone, PartialEq)]
- pub struct PingBody<'a> {
- pub _tab: flatbuffers::Table<'a>,
+pub struct PingBody<'a> {
+ pub _tab: flatbuffers::Table<'a>,
+}
+
+impl<'a> flatbuffers::Follow<'a> for PingBody<'a> {
+ type Inner = PingBody<'a>;
+ #[inline]
+ unsafe fn follow(buf: &'a [u8], loc: usize) -> Self::Inner {
+ Self { _tab: flatbuffers::Table::new(buf, loc) }
+ }
+}
+
+impl<'a> PingBody<'a> {
+ pub const VT_PAYLOAD: flatbuffers::VOffsetT = 4;
+
+ pub const fn get_fully_qualified_name() -> &'static str {
+ "models.PingBody"
+ }
+
+ #[inline]
+ pub unsafe fn init_from_table(table: flatbuffers::Table<'a>) -> Self {
+ PingBody { _tab: table }
+ }
+ #[allow(unused_mut)]
+ pub fn create<'bldr: 'args, 'args: 'mut_bldr, 'mut_bldr, A: flatbuffers::Allocator + 'bldr>(
+ _fbb: &'mut_bldr mut flatbuffers::FlatBufferBuilder<'bldr, A>,
+ args: &'args PingBodyArgs<'args>
+ ) -> flatbuffers::WIPOffset> {
+ let mut builder = PingBodyBuilder::new(_fbb);
+ if let Some(x) = args.payload { builder.add_payload(x); }
+ builder.finish()
+ }
+
+
+ #[inline]
+ pub fn payload(&self) -> Option> {
+ // Safety:
+ // Created from valid Table for this object
+ // which contains a valid value in this slot
+ unsafe { self._tab.get::>>(PingBody::VT_PAYLOAD, None)}
+ }
+}
+
+impl flatbuffers::Verifiable for PingBody<'_> {
+ #[inline]
+ fn run_verifier(
+ v: &mut flatbuffers::Verifier, pos: usize
+ ) -> Result<(), flatbuffers::InvalidFlatbuffer> {
+ use self::flatbuffers::Verifiable;
+ v.visit_table(pos)?
+ .visit_field::>>("payload", Self::VT_PAYLOAD, false)?
+ .finish();
+ Ok(())
+ }
+}
+pub struct PingBodyArgs<'a> {
+ pub payload: Option>>,
+}
+impl<'a> Default for PingBodyArgs<'a> {
+ #[inline]
+ fn default() -> Self {
+ PingBodyArgs {
+ payload: None,
}
+ }
+}
- impl<'a> flatbuffers::Follow<'a> for PingBody<'a> {
- type Inner = PingBody<'a>;
- #[inline]
- unsafe fn follow(buf: &'a [u8], loc: usize) -> Self::Inner {
- Self {
- _tab: flatbuffers::Table::new(buf, loc),
- }
- }
+pub struct PingBodyBuilder<'a: 'b, 'b, A: flatbuffers::Allocator + 'a> {
+ fbb_: &'b mut flatbuffers::FlatBufferBuilder<'a, A>,
+ start_: flatbuffers::WIPOffset,
+}
+impl<'a: 'b, 'b, A: flatbuffers::Allocator + 'a> PingBodyBuilder<'a, 'b, A> {
+ #[inline]
+ pub fn add_payload(&mut self, payload: flatbuffers::WIPOffset>) {
+ self.fbb_.push_slot_always::>(PingBody::VT_PAYLOAD, payload);
+ }
+ #[inline]
+ pub fn new(_fbb: &'b mut flatbuffers::FlatBufferBuilder<'a, A>) -> PingBodyBuilder<'a, 'b, A> {
+ let start = _fbb.start_table();
+ PingBodyBuilder {
+ fbb_: _fbb,
+ start_: start,
}
+ }
+ #[inline]
+ pub fn finish(self) -> flatbuffers::WIPOffset> {
+ let o = self.fbb_.end_table(self.start_);
+ flatbuffers::WIPOffset::new(o.value())
+ }
+}
- impl<'a> PingBody<'a> {
- pub const VT_PAYLOAD: flatbuffers::VOffsetT = 4;
+impl core::fmt::Debug for PingBody<'_> {
+ fn fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
+ let mut ds = f.debug_struct("PingBody");
+ ds.field("payload", &self.payload());
+ ds.finish()
+ }
+}
+} // pub mod models
- pub const fn get_fully_qualified_name() -> &'static str {
- "models.PingBody"
- }
-
- #[inline]
- pub unsafe fn init_from_table(table: flatbuffers::Table<'a>) -> Self {
- PingBody { _tab: table }
- }
- #[allow(unused_mut)]
- pub fn create<'bldr: 'args, 'args: 'mut_bldr, 'mut_bldr, A: flatbuffers::Allocator + 'bldr>(
- _fbb: &'mut_bldr mut flatbuffers::FlatBufferBuilder<'bldr, A>,
- args: &'args PingBodyArgs<'args>,
- ) -> flatbuffers::WIPOffset> {
- let mut builder = PingBodyBuilder::new(_fbb);
- if let Some(x) = args.payload {
- builder.add_payload(x);
- }
- builder.finish()
- }
-
- #[inline]
- pub fn payload(&self) -> Option> {
- // Safety:
- // Created from valid Table for this object
- // which contains a valid value in this slot
- unsafe {
- self._tab
- .get::>>(PingBody::VT_PAYLOAD, None)
- }
- }
- }
-
- impl flatbuffers::Verifiable for PingBody<'_> {
- #[inline]
- fn run_verifier(v: &mut flatbuffers::Verifier, pos: usize) -> Result<(), flatbuffers::InvalidFlatbuffer> {
- use self::flatbuffers::Verifiable;
- v.visit_table(pos)?
- .visit_field::>>("payload", Self::VT_PAYLOAD, false)?
- .finish();
- Ok(())
- }
- }
- pub struct PingBodyArgs<'a> {
- pub payload: Option>>,
- }
- impl<'a> Default for PingBodyArgs<'a> {
- #[inline]
- fn default() -> Self {
- PingBodyArgs { payload: None }
- }
- }
-
- pub struct PingBodyBuilder<'a: 'b, 'b, A: flatbuffers::Allocator + 'a> {
- fbb_: &'b mut flatbuffers::FlatBufferBuilder<'a, A>,
- start_: flatbuffers::WIPOffset,
- }
- impl<'a: 'b, 'b, A: flatbuffers::Allocator + 'a> PingBodyBuilder<'a, 'b, A> {
- #[inline]
- pub fn add_payload(&mut self, payload: flatbuffers::WIPOffset>) {
- self.fbb_
- .push_slot_always::>(PingBody::VT_PAYLOAD, payload);
- }
- #[inline]
- pub fn new(_fbb: &'b mut flatbuffers::FlatBufferBuilder<'a, A>) -> PingBodyBuilder<'a, 'b, A> {
- let start = _fbb.start_table();
- PingBodyBuilder {
- fbb_: _fbb,
- start_: start,
- }
- }
- #[inline]
- pub fn finish(self) -> flatbuffers::WIPOffset> {
- let o = self.fbb_.end_table(self.start_);
- flatbuffers::WIPOffset::new(o.value())
- }
- }
-
- impl core::fmt::Debug for PingBody<'_> {
- fn fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
- let mut ds = f.debug_struct("PingBody");
- ds.field("payload", &self.payload());
- ds.finish()
- }
- }
-} // pub mod models
diff --git a/common/protos/src/generated/proto_gen/node_service.rs b/common/protos/src/generated/proto_gen/node_service.rs
index 000d5b48..88f7b3ab 100644
--- a/common/protos/src/generated/proto_gen/node_service.rs
+++ b/common/protos/src/generated/proto_gen/node_service.rs
@@ -622,7 +622,10 @@ pub struct GenerallyLockResponse {
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Mss {
#[prost(map = "string, string", tag = "1")]
- pub value: ::std::collections::HashMap<::prost::alloc::string::String, ::prost::alloc::string::String>,
+ pub value: ::std::collections::HashMap<
+ ::prost::alloc::string::String,
+ ::prost::alloc::string::String,
+ >,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct LocalStorageInfoRequest {
@@ -786,7 +789,10 @@ pub struct DownloadProfileDataResponse {
#[prost(bool, tag = "1")]
pub success: bool,
#[prost(map = "string, bytes", tag = "2")]
- pub data: ::std::collections::HashMap<::prost::alloc::string::String, ::prost::alloc::vec::Vec>,
+ pub data: ::std::collections::HashMap<
+ ::prost::alloc::string::String,
+ ::prost::alloc::vec::Vec,
+ >,
#[prost(string, optional, tag = "3")]
pub error_info: ::core::option::Option<::prost::alloc::string::String>,
}
@@ -1053,9 +1059,15 @@ pub struct LoadTransitionTierConfigResponse {
}
/// Generated client implementations.
pub mod node_service_client {
- #![allow(unused_variables, dead_code, missing_docs, clippy::wildcard_imports, clippy::let_unit_value)]
- use tonic::codegen::http::Uri;
+ #![allow(
+ unused_variables,
+ dead_code,
+ missing_docs,
+ clippy::wildcard_imports,
+ clippy::let_unit_value,
+ )]
use tonic::codegen::*;
+ use tonic::codegen::http::Uri;
#[derive(Debug, Clone)]
pub struct NodeServiceClient {
inner: tonic::client::Grpc,
@@ -1086,16 +1098,22 @@ pub mod node_service_client {
let inner = tonic::client::Grpc::with_origin(inner, origin);
Self { inner }
}
- pub fn with_interceptor(inner: T, interceptor: F) -> NodeServiceClient>
+ pub fn with_interceptor(
+ inner: T,
+ interceptor: F,
+ ) -> NodeServiceClient>
where
F: tonic::service::Interceptor,
T::ResponseBody: Default,
T: tonic::codegen::Service<
http::Request,
- Response = http::Response<>::ResponseBody>,
+ Response = http::Response<
+ >::ResponseBody,
+ >,
>,
- >>::Error:
- Into + std::marker::Send + std::marker::Sync,
+ ,
+ >>::Error: Into + std::marker::Send + std::marker::Sync,
{
NodeServiceClient::new(InterceptedService::new(inner, interceptor))
}
@@ -1138,9 +1156,15 @@ pub mod node_service_client {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/Ping");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/Ping",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "Ping"));
@@ -1149,13 +1173,22 @@ pub mod node_service_client {
pub async fn heal_bucket(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/HealBucket");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/HealBucket",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "HealBucket"));
@@ -1164,13 +1197,22 @@ pub mod node_service_client {
pub async fn list_bucket(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/ListBucket");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/ListBucket",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "ListBucket"));
@@ -1179,13 +1221,22 @@ pub mod node_service_client {
pub async fn make_bucket(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/MakeBucket");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/MakeBucket",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "MakeBucket"));
@@ -1194,13 +1245,22 @@ pub mod node_service_client {
pub async fn get_bucket_info(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/GetBucketInfo");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/GetBucketInfo",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "GetBucketInfo"));
@@ -1209,13 +1269,22 @@ pub mod node_service_client {
pub async fn delete_bucket(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/DeleteBucket");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/DeleteBucket",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "DeleteBucket"));
@@ -1224,13 +1293,22 @@ pub mod node_service_client {
pub async fn read_all(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/ReadAll");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/ReadAll",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "ReadAll"));
@@ -1239,13 +1317,22 @@ pub mod node_service_client {
pub async fn write_all(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/WriteAll");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/WriteAll",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "WriteAll"));
@@ -1258,9 +1345,15 @@ pub mod node_service_client {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/Delete");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/Delete",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "Delete"));
@@ -1269,13 +1362,22 @@ pub mod node_service_client {
pub async fn verify_file(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/VerifyFile");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/VerifyFile",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "VerifyFile"));
@@ -1284,13 +1386,22 @@ pub mod node_service_client {
pub async fn check_parts(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/CheckParts");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/CheckParts",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "CheckParts"));
@@ -1299,13 +1410,22 @@ pub mod node_service_client {
pub async fn rename_part(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/RenamePart");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/RenamePart",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "RenamePart"));
@@ -1314,13 +1434,22 @@ pub mod node_service_client {
pub async fn rename_file(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/RenameFile");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/RenameFile",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "RenameFile"));
@@ -1333,9 +1462,15 @@ pub mod node_service_client {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/Write");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/Write",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "Write"));
@@ -1344,13 +1479,22 @@ pub mod node_service_client {
pub async fn write_stream(
&mut self,
request: impl tonic::IntoStreamingRequest,
- ) -> std::result::Result>, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response>,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/WriteStream");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/WriteStream",
+ );
let mut req = request.into_streaming_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "WriteStream"));
@@ -1360,13 +1504,22 @@ pub mod node_service_client {
pub async fn read_at(
&mut self,
request: impl tonic::IntoStreamingRequest,
- ) -> std::result::Result>, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response>,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/ReadAt");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/ReadAt",
+ );
let mut req = request.into_streaming_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "ReadAt"));
@@ -1375,13 +1528,22 @@ pub mod node_service_client {
pub async fn list_dir(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/ListDir");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/ListDir",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "ListDir"));
@@ -1390,13 +1552,22 @@ pub mod node_service_client {
pub async fn walk_dir(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result>, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response>,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/WalkDir");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/WalkDir",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "WalkDir"));
@@ -1405,13 +1576,22 @@ pub mod node_service_client {
pub async fn rename_data(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/RenameData");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/RenameData",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "RenameData"));
@@ -1420,13 +1600,22 @@ pub mod node_service_client {
pub async fn make_volumes(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/MakeVolumes");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/MakeVolumes",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "MakeVolumes"));
@@ -1435,13 +1624,22 @@ pub mod node_service_client {
pub async fn make_volume(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/MakeVolume");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/MakeVolume",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "MakeVolume"));
@@ -1450,13 +1648,22 @@ pub mod node_service_client {
pub async fn list_volumes(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/ListVolumes");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/ListVolumes",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "ListVolumes"));
@@ -1465,13 +1672,22 @@ pub mod node_service_client {
pub async fn stat_volume(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/StatVolume");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/StatVolume",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "StatVolume"));
@@ -1480,13 +1696,22 @@ pub mod node_service_client {
pub async fn delete_paths(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/DeletePaths");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/DeletePaths",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "DeletePaths"));
@@ -1495,13 +1720,22 @@ pub mod node_service_client {
pub async fn update_metadata(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/UpdateMetadata");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/UpdateMetadata",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "UpdateMetadata"));
@@ -1510,13 +1744,22 @@ pub mod node_service_client {
pub async fn write_metadata(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/WriteMetadata");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/WriteMetadata",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "WriteMetadata"));
@@ -1525,13 +1768,22 @@ pub mod node_service_client {
pub async fn read_version(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/ReadVersion");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/ReadVersion",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "ReadVersion"));
@@ -1544,9 +1796,15 @@ pub mod node_service_client {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/ReadXL");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/ReadXL",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "ReadXL"));
@@ -1555,13 +1813,22 @@ pub mod node_service_client {
pub async fn delete_version(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/DeleteVersion");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/DeleteVersion",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "DeleteVersion"));
@@ -1570,13 +1837,22 @@ pub mod node_service_client {
pub async fn delete_versions(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/DeleteVersions");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/DeleteVersions",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "DeleteVersions"));
@@ -1585,13 +1861,22 @@ pub mod node_service_client {
pub async fn read_multiple(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/ReadMultiple");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/ReadMultiple",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "ReadMultiple"));
@@ -1600,13 +1885,22 @@ pub mod node_service_client {
pub async fn delete_volume(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/DeleteVolume");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/DeleteVolume",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "DeleteVolume"));
@@ -1615,13 +1909,22 @@ pub mod node_service_client {
pub async fn disk_info(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/DiskInfo");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/DiskInfo",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "DiskInfo"));
@@ -1630,13 +1933,22 @@ pub mod node_service_client {
pub async fn ns_scanner(
&mut self,
request: impl tonic::IntoStreamingRequest,
- ) -> std::result::Result>, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response>,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/NsScanner");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/NsScanner",
+ );
let mut req = request.into_streaming_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "NsScanner"));
@@ -1645,13 +1957,22 @@ pub mod node_service_client {
pub async fn lock(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/Lock");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/Lock",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "Lock"));
@@ -1660,13 +1981,22 @@ pub mod node_service_client {
pub async fn un_lock(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/UnLock");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/UnLock",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "UnLock"));
@@ -1675,13 +2005,22 @@ pub mod node_service_client {
pub async fn r_lock(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/RLock");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/RLock",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "RLock"));
@@ -1690,13 +2029,22 @@ pub mod node_service_client {
pub async fn r_un_lock(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/RUnLock");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/RUnLock",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "RUnLock"));
@@ -1705,13 +2053,22 @@ pub mod node_service_client {
pub async fn force_un_lock(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/ForceUnLock");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/ForceUnLock",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "ForceUnLock"));
@@ -1720,13 +2077,22 @@ pub mod node_service_client {
pub async fn refresh(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/Refresh");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/Refresh",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "Refresh"));
@@ -1735,13 +2101,22 @@ pub mod node_service_client {
pub async fn local_storage_info(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/LocalStorageInfo");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/LocalStorageInfo",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "LocalStorageInfo"));
@@ -1750,13 +2125,22 @@ pub mod node_service_client {
pub async fn server_info(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/ServerInfo");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/ServerInfo",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "ServerInfo"));
@@ -1765,13 +2149,22 @@ pub mod node_service_client {
pub async fn get_cpus(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/GetCpus");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/GetCpus",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "GetCpus"));
@@ -1780,13 +2173,22 @@ pub mod node_service_client {
pub async fn get_net_info(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/GetNetInfo");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/GetNetInfo",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "GetNetInfo"));
@@ -1795,13 +2197,22 @@ pub mod node_service_client {
pub async fn get_partitions(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/GetPartitions");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/GetPartitions",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "GetPartitions"));
@@ -1810,13 +2221,22 @@ pub mod node_service_client {
pub async fn get_os_info(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/GetOsInfo");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/GetOsInfo",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "GetOsInfo"));
@@ -1825,13 +2245,22 @@ pub mod node_service_client {
pub async fn get_se_linux_info(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/GetSELinuxInfo");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/GetSELinuxInfo",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "GetSELinuxInfo"));
@@ -1840,13 +2269,22 @@ pub mod node_service_client {
pub async fn get_sys_config(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/GetSysConfig");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/GetSysConfig",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "GetSysConfig"));
@@ -1855,13 +2293,22 @@ pub mod node_service_client {
pub async fn get_sys_errors(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/GetSysErrors");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/GetSysErrors",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "GetSysErrors"));
@@ -1870,13 +2317,22 @@ pub mod node_service_client {
pub async fn get_mem_info(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/GetMemInfo");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/GetMemInfo",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "GetMemInfo"));
@@ -1885,13 +2341,22 @@ pub mod node_service_client {
pub async fn get_metrics(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/GetMetrics");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/GetMetrics",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "GetMetrics"));
@@ -1900,13 +2365,22 @@ pub mod node_service_client {
pub async fn get_proc_info(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/GetProcInfo");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/GetProcInfo",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "GetProcInfo"));
@@ -1915,13 +2389,22 @@ pub mod node_service_client {
pub async fn start_profiling(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/StartProfiling");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/StartProfiling",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "StartProfiling"));
@@ -1930,28 +2413,48 @@ pub mod node_service_client {
pub async fn download_profile_data(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/DownloadProfileData");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/DownloadProfileData",
+ );
let mut req = request.into_request();
req.extensions_mut()
- .insert(GrpcMethod::new("node_service.NodeService", "DownloadProfileData"));
+ .insert(
+ GrpcMethod::new("node_service.NodeService", "DownloadProfileData"),
+ );
self.inner.unary(req, path, codec).await
}
pub async fn get_bucket_stats(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/GetBucketStats");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/GetBucketStats",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "GetBucketStats"));
@@ -1960,13 +2463,22 @@ pub mod node_service_client {
pub async fn get_sr_metrics(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/GetSRMetrics");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/GetSRMetrics",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "GetSRMetrics"));
@@ -1975,58 +2487,100 @@ pub mod node_service_client {
pub async fn get_all_bucket_stats(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/GetAllBucketStats");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/GetAllBucketStats",
+ );
let mut req = request.into_request();
req.extensions_mut()
- .insert(GrpcMethod::new("node_service.NodeService", "GetAllBucketStats"));
+ .insert(
+ GrpcMethod::new("node_service.NodeService", "GetAllBucketStats"),
+ );
self.inner.unary(req, path, codec).await
}
pub async fn load_bucket_metadata(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/LoadBucketMetadata");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/LoadBucketMetadata",
+ );
let mut req = request.into_request();
req.extensions_mut()
- .insert(GrpcMethod::new("node_service.NodeService", "LoadBucketMetadata"));
+ .insert(
+ GrpcMethod::new("node_service.NodeService", "LoadBucketMetadata"),
+ );
self.inner.unary(req, path, codec).await
}
pub async fn delete_bucket_metadata(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/DeleteBucketMetadata");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/DeleteBucketMetadata",
+ );
let mut req = request.into_request();
req.extensions_mut()
- .insert(GrpcMethod::new("node_service.NodeService", "DeleteBucketMetadata"));
+ .insert(
+ GrpcMethod::new("node_service.NodeService", "DeleteBucketMetadata"),
+ );
self.inner.unary(req, path, codec).await
}
pub async fn delete_policy(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/DeletePolicy");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/DeletePolicy",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "DeletePolicy"));
@@ -2035,13 +2589,22 @@ pub mod node_service_client {
pub async fn load_policy(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/LoadPolicy");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/LoadPolicy",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "LoadPolicy"));
@@ -2050,28 +2613,48 @@ pub mod node_service_client {
pub async fn load_policy_mapping(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/LoadPolicyMapping");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/LoadPolicyMapping",
+ );
let mut req = request.into_request();
req.extensions_mut()
- .insert(GrpcMethod::new("node_service.NodeService", "LoadPolicyMapping"));
+ .insert(
+ GrpcMethod::new("node_service.NodeService", "LoadPolicyMapping"),
+ );
self.inner.unary(req, path, codec).await
}
pub async fn delete_user(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/DeleteUser");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/DeleteUser",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "DeleteUser"));
@@ -2080,28 +2663,48 @@ pub mod node_service_client {
pub async fn delete_service_account(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/DeleteServiceAccount");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/DeleteServiceAccount",
+ );
let mut req = request.into_request();
req.extensions_mut()
- .insert(GrpcMethod::new("node_service.NodeService", "DeleteServiceAccount"));
+ .insert(
+ GrpcMethod::new("node_service.NodeService", "DeleteServiceAccount"),
+ );
self.inner.unary(req, path, codec).await
}
pub async fn load_user(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/LoadUser");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/LoadUser",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "LoadUser"));
@@ -2110,28 +2713,48 @@ pub mod node_service_client {
pub async fn load_service_account(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/LoadServiceAccount");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/LoadServiceAccount",
+ );
let mut req = request.into_request();
req.extensions_mut()
- .insert(GrpcMethod::new("node_service.NodeService", "LoadServiceAccount"));
+ .insert(
+ GrpcMethod::new("node_service.NodeService", "LoadServiceAccount"),
+ );
self.inner.unary(req, path, codec).await
}
pub async fn load_group(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/LoadGroup");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/LoadGroup",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "LoadGroup"));
@@ -2140,16 +2763,30 @@ pub mod node_service_client {
pub async fn reload_site_replication_config(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/ReloadSiteReplicationConfig");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/ReloadSiteReplicationConfig",
+ );
let mut req = request.into_request();
req.extensions_mut()
- .insert(GrpcMethod::new("node_service.NodeService", "ReloadSiteReplicationConfig"));
+ .insert(
+ GrpcMethod::new(
+ "node_service.NodeService",
+ "ReloadSiteReplicationConfig",
+ ),
+ );
self.inner.unary(req, path, codec).await
}
/// rpc VerifyBinary() returns () {};
@@ -2157,13 +2794,22 @@ pub mod node_service_client {
pub async fn signal_service(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/SignalService");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/SignalService",
+ );
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("node_service.NodeService", "SignalService"));
@@ -2172,58 +2818,100 @@ pub mod node_service_client {
pub async fn background_heal_status(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/BackgroundHealStatus");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/BackgroundHealStatus",
+ );
let mut req = request.into_request();
req.extensions_mut()
- .insert(GrpcMethod::new("node_service.NodeService", "BackgroundHealStatus"));
+ .insert(
+ GrpcMethod::new("node_service.NodeService", "BackgroundHealStatus"),
+ );
self.inner.unary(req, path, codec).await
}
pub async fn get_metacache_listing(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/GetMetacacheListing");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/GetMetacacheListing",
+ );
let mut req = request.into_request();
req.extensions_mut()
- .insert(GrpcMethod::new("node_service.NodeService", "GetMetacacheListing"));
+ .insert(
+ GrpcMethod::new("node_service.NodeService", "GetMetacacheListing"),
+ );
self.inner.unary(req, path, codec).await
}
pub async fn update_metacache_listing(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response,
+ tonic::Status,
+ > {
self.inner
.ready()
.await
- .map_err(|e| tonic::Status::unknown(format!("Service was not ready: {}", e.into())))?;
+ .map_err(|e| {
+ tonic::Status::unknown(
+ format!("Service was not ready: {}", e.into()),
+ )
+ })?;
let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static("/node_service.NodeService/UpdateMetacacheListing");
+ let path = http::uri::PathAndQuery::from_static(
+ "/node_service.NodeService/UpdateMetacacheListing",
+ );
let mut req = request.into_request();
req.extensions_mut()
- .insert(GrpcMethod::new("node_service.NodeService", "UpdateMetacacheListing"));
+ .insert(
+ GrpcMethod::new("node_service.NodeService", "UpdateMetacacheListing"),
+ );
self.inner.unary(req, path, codec).await
}
pub async fn reload_pool_meta(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result, tonic::Status> {
+ ) -> std::result::Result<
+ tonic::Response