gsadmin/rustfs
1
0
Fork 0
mirror of https://github.com/rustfs/rustfs.git synced 2026-08-17 18:27:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #458 from rustfs/fix/proto-spelling-errors

Browse Source 
fix: correct spelling errors in proto file `RenamePartRequst`
This commit is contained in:
loverustfs
2025-06-10 22:16:21 +08:00
committed by GitHub
parent 682ad8742d e6b931f71e
commit 7ca9f44fca
4 changed files with 24 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files
common/protos/src/generated/proto_gen/node_service.rs
+10 -10
View File
@@ -191,7 +191,7 @@ pub struct CheckPartsResponse {
pub error: ::core::option::Option<Error>, pub error: ::core::option::Option<Error>,
} }
#[derive(Clone, PartialEq, ::prost::Message)] #[derive(Clone, PartialEq, ::prost::Message)]
pub struct RenamePartRequst { pub struct RenamePartRequest {
#[prost(string, tag = "1")] #[prost(string, tag = "1")]
pub disk: ::prost::alloc::string::String, pub disk: ::prost::alloc::string::String,
#[prost(string, tag = "2")] #[prost(string, tag = "2")]
@@ -213,7 +213,7 @@ pub struct RenamePartResponse {
pub error: ::core::option::Option<Error>, pub error: ::core::option::Option<Error>,
} }
#[derive(Clone, PartialEq, ::prost::Message)] #[derive(Clone, PartialEq, ::prost::Message)]
pub struct RenameFileRequst { pub struct RenameFileRequest {
#[prost(string, tag = "1")] #[prost(string, tag = "1")]
pub disk: ::prost::alloc::string::String, pub disk: ::prost::alloc::string::String,
#[prost(string, tag = "2")] #[prost(string, tag = "2")]
@@ -1298,7 +1298,7 @@ pub mod node_service_client {
} }
pub async fn rename_part( pub async fn rename_part(
&mut self, &mut self,
request: impl tonic::IntoRequest<super::RenamePartRequst>, request: impl tonic::IntoRequest<super::RenamePartRequest>,
) -> std::result::Result<tonic::Response<super::RenamePartResponse>, tonic::Status> { ) -> std::result::Result<tonic::Response<super::RenamePartResponse>, tonic::Status> {
self.inner self.inner
.ready() .ready()
@@ -1313,7 +1313,7 @@ pub mod node_service_client {
} }
pub async fn rename_file( pub async fn rename_file(
&mut self, &mut self,
request: impl tonic::IntoRequest<super::RenameFileRequst>, request: impl tonic::IntoRequest<super::RenameFileRequest>,
) -> std::result::Result<tonic::Response<super::RenameFileResponse>, tonic::Status> { ) -> std::result::Result<tonic::Response<super::RenameFileResponse>, tonic::Status> {
self.inner self.inner
.ready() .ready()
@@ -2330,11 +2330,11 @@ pub mod node_service_server {
) -> std::result::Result<tonic::Response<super::CheckPartsResponse>, tonic::Status>; ) -> std::result::Result<tonic::Response<super::CheckPartsResponse>, tonic::Status>;
async fn rename_part( async fn rename_part(
&self, &self,
request: tonic::Request<super::RenamePartRequst>, request: tonic::Request<super::RenamePartRequest>,
) -> std::result::Result<tonic::Response<super::RenamePartResponse>, tonic::Status>; ) -> std::result::Result<tonic::Response<super::RenamePartResponse>, tonic::Status>;
async fn rename_file( async fn rename_file(
&self, &self,
request: tonic::Request<super::RenameFileRequst>, request: tonic::Request<super::RenameFileRequest>,
) -> std::result::Result<tonic::Response<super::RenameFileResponse>, tonic::Status>; ) -> std::result::Result<tonic::Response<super::RenameFileResponse>, tonic::Status>;
async fn write( async fn write(
&self, &self,
@@ -2989,10 +2989,10 @@ pub mod node_service_server {
"/node_service.NodeService/RenamePart" => { "/node_service.NodeService/RenamePart" => {
#[allow(non_camel_case_types)] #[allow(non_camel_case_types)]
struct RenamePartSvc<T: NodeService>(pub Arc<T>); struct RenamePartSvc<T: NodeService>(pub Arc<T>);
impl<T: NodeService> tonic::server::UnaryService<super::RenamePartRequst> for RenamePartSvc<T> { impl<T: NodeService> tonic::server::UnaryService<super::RenamePartRequest> for RenamePartSvc<T> {
type Response = super::RenamePartResponse; type Response = super::RenamePartResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>; type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(&mut self, request: tonic::Request<super::RenamePartRequst>) -> Self::Future { fn call(&mut self, request: tonic::Request<super::RenamePartRequest>) -> Self::Future {
let inner = Arc::clone(&self.0); let inner = Arc::clone(&self.0);
let fut = async move { <T as NodeService>::rename_part(&inner, request).await }; let fut = async move { <T as NodeService>::rename_part(&inner, request).await };
Box::pin(fut) Box::pin(fut)
@@ -3017,10 +3017,10 @@ pub mod node_service_server {
"/node_service.NodeService/RenameFile" => { "/node_service.NodeService/RenameFile" => {
#[allow(non_camel_case_types)] #[allow(non_camel_case_types)]
struct RenameFileSvc<T: NodeService>(pub Arc<T>); struct RenameFileSvc<T: NodeService>(pub Arc<T>);
impl<T: NodeService> tonic::server::UnaryService<super::RenameFileRequst> for RenameFileSvc<T> { impl<T: NodeService> tonic::server::UnaryService<super::RenameFileRequest> for RenameFileSvc<T> {
type Response = super::RenameFileResponse; type Response = super::RenameFileResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>; type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(&mut self, request: tonic::Request<super::RenameFileRequst>) -> Self::Future { fn call(&mut self, request: tonic::Request<super::RenameFileRequest>) -> Self::Future {
let inner = Arc::clone(&self.0); let inner = Arc::clone(&self.0);
let fut = async move { <T as NodeService>::rename_file(&inner, request).await }; let fut = async move { <T as NodeService>::rename_file(&inner, request).await };
Box::pin(fut) Box::pin(fut)
common/protos/src/node.proto
+5 -5
View File
@@ -129,7 +129,7 @@ message CheckPartsResponse {
optional Error error = 3; optional Error error = 3;
} }
message RenamePartRequst { message RenamePartRequest {
string disk = 1; string disk = 1;
string src_volume = 2; string src_volume = 2;
string src_path = 3; string src_path = 3;
@@ -143,7 +143,7 @@ message RenamePartResponse {
optional Error error = 2; optional Error error = 2;
} }
message RenameFileRequst { message RenameFileRequest {
string disk = 1; string disk = 1;
string src_volume = 2; string src_volume = 2;
string src_path = 3; string src_path = 3;
@@ -175,7 +175,7 @@ message WriteResponse {
// string path = 3; // string path = 3;
// bytes data = 4; // bytes data = 4;
// } // }
// //
// message AppendResponse { // message AppendResponse {
// bool success = 1; // bool success = 1;
// optional Error error = 2; // optional Error error = 2;
@@ -755,8 +755,8 @@ service NodeService {
rpc Delete(DeleteRequest) returns (DeleteResponse) {}; rpc Delete(DeleteRequest) returns (DeleteResponse) {};
rpc VerifyFile(VerifyFileRequest) returns (VerifyFileResponse) {}; rpc VerifyFile(VerifyFileRequest) returns (VerifyFileResponse) {};
rpc CheckParts(CheckPartsRequest) returns (CheckPartsResponse) {}; rpc CheckParts(CheckPartsRequest) returns (CheckPartsResponse) {};
rpc RenamePart(RenamePartRequst) returns (RenamePartResponse) {}; rpc RenamePart(RenamePartRequest) returns (RenamePartResponse) {};
rpc RenameFile(RenameFileRequst) returns (RenameFileResponse) {}; rpc RenameFile(RenameFileRequest) returns (RenameFileResponse) {};
rpc Write(WriteRequest) returns (WriteResponse) {}; rpc Write(WriteRequest) returns (WriteResponse) {};
rpc WriteStream(stream WriteRequest) returns (stream WriteResponse) {}; rpc WriteStream(stream WriteRequest) returns (stream WriteResponse) {};
// rpc Append(AppendRequest) returns (AppendResponse) {}; // rpc Append(AppendRequest) returns (AppendResponse) {};
ecstore/src/disk/remote.rs
+4 -4
View File
@@ -7,7 +7,7 @@ use protos::{
proto_gen::node_service::{ proto_gen::node_service::{
CheckPartsRequest, DeletePathsRequest, DeleteRequest, DeleteVersionRequest, DeleteVersionsRequest, DeleteVolumeRequest, CheckPartsRequest, DeletePathsRequest, DeleteRequest, DeleteVersionRequest, DeleteVersionsRequest, DeleteVolumeRequest,
DiskInfoRequest, ListDirRequest, ListVolumesRequest, MakeVolumeRequest, MakeVolumesRequest, NsScannerRequest, DiskInfoRequest, ListDirRequest, ListVolumesRequest, MakeVolumeRequest, MakeVolumesRequest, NsScannerRequest,
ReadAllRequest, ReadMultipleRequest, ReadVersionRequest, ReadXlRequest, RenameDataRequest, RenameFileRequst, ReadAllRequest, ReadMultipleRequest, ReadVersionRequest, ReadXlRequest, RenameDataRequest, RenameFileRequest,
StatVolumeRequest, UpdateMetadataRequest, VerifyFileRequest, WalkDirRequest, WriteAllRequest, WriteMetadataRequest, StatVolumeRequest, UpdateMetadataRequest, VerifyFileRequest, WalkDirRequest, WriteAllRequest, WriteMetadataRequest,
}, },
}; };
@@ -40,7 +40,7 @@ use crate::{
}, },
}; };
use protos::proto_gen::node_service::RenamePartRequst; use protos::proto_gen::node_service::RenamePartRequest;
#[derive(Debug)] #[derive(Debug)]
pub struct RemoteDisk { pub struct RemoteDisk {
@@ -631,7 +631,7 @@ impl DiskAPI for RemoteDisk {
let mut client = node_service_time_out_client(&self.addr) let mut client = node_service_time_out_client(&self.addr)
.await .await
.map_err(|err| Error::other(format!("can not get client, err: {}", err)))?; .map_err(|err| Error::other(format!("can not get client, err: {}", err)))?;
let request = Request::new(RenameFileRequst { let request = Request::new(RenameFileRequest {
disk: self.endpoint.to_string(), disk: self.endpoint.to_string(),
src_volume: src_volume.to_string(), src_volume: src_volume.to_string(),
src_path: src_path.to_string(), src_path: src_path.to_string(),
@@ -654,7 +654,7 @@ impl DiskAPI for RemoteDisk {
let mut client = node_service_time_out_client(&self.addr) let mut client = node_service_time_out_client(&self.addr)
.await .await
.map_err(|err| Error::other(format!("can not get client, err: {}", err)))?; .map_err(|err| Error::other(format!("can not get client, err: {}", err)))?;
let request = Request::new(RenamePartRequst { let request = Request::new(RenamePartRequest {
disk: self.endpoint.to_string(), disk: self.endpoint.to_string(),
src_volume: src_volume.to_string(), src_volume: src_volume.to_string(),
src_path: src_path.to_string(), src_path: src_path.to_string(),
rustfs/src/grpc.rs
+5 -5
View File
@@ -437,7 +437,7 @@ impl Node for NodeService {
} }
} }
async fn rename_part(&self, request: Request<RenamePartRequst>) -> Result<Response<RenamePartResponse>, Status> { async fn rename_part(&self, request: Request<RenamePartRequest>) -> Result<Response<RenamePartResponse>, Status> {
let request = request.into_inner(); let request = request.into_inner();
if let Some(disk) = self.find_disk(&request.disk).await { if let Some(disk) = self.find_disk(&request.disk).await {
match disk match disk
@@ -467,7 +467,7 @@ impl Node for NodeService {
} }
} }
async fn rename_file(&self, request: Request<RenameFileRequst>) -> Result<Response<RenameFileResponse>, Status> { async fn rename_file(&self, request: Request<RenameFileRequest>) -> Result<Response<RenameFileResponse>, Status> {
let request = request.into_inner(); let request = request.into_inner();
if let Some(disk) = self.find_disk(&request.disk).await { if let Some(disk) = self.find_disk(&request.disk).await {
match disk match disk
@@ -2224,7 +2224,7 @@ mod tests {
Mss, PingRequest, PingResponse, ReadAllRequest, ReadAllResponse, ReadMultipleRequest, ReadMultipleResponse, Mss, PingRequest, PingResponse, ReadAllRequest, ReadAllResponse, ReadMultipleRequest, ReadMultipleResponse,
ReadVersionRequest, ReadVersionResponse, ReadXlRequest, ReadXlResponse, ReloadPoolMetaRequest, ReloadPoolMetaResponse, ReadVersionRequest, ReadVersionResponse, ReadXlRequest, ReadXlResponse, ReloadPoolMetaRequest, ReloadPoolMetaResponse,
ReloadSiteReplicationConfigRequest, ReloadSiteReplicationConfigResponse, RenameDataRequest, RenameDataResponse, ReloadSiteReplicationConfigRequest, ReloadSiteReplicationConfigResponse, RenameDataRequest, RenameDataResponse,
RenameFileRequst, RenameFileResponse, RenamePartRequst, RenamePartResponse, ServerInfoRequest, ServerInfoResponse, RenameFileRequest, RenameFileResponse, RenamePartRequest, RenamePartResponse, ServerInfoRequest, ServerInfoResponse,
SignalServiceRequest, SignalServiceResponse, StatVolumeRequest, StatVolumeResponse, StopRebalanceRequest, SignalServiceRequest, SignalServiceResponse, StatVolumeRequest, StatVolumeResponse, StopRebalanceRequest,
StopRebalanceResponse, UpdateMetadataRequest, UpdateMetadataResponse, VerifyFileRequest, VerifyFileResponse, StopRebalanceResponse, UpdateMetadataRequest, UpdateMetadataResponse, VerifyFileRequest, VerifyFileResponse,
WriteAllRequest, WriteAllResponse, WriteMetadataRequest, WriteMetadataResponse, WriteAllRequest, WriteAllResponse, WriteMetadataRequest, WriteMetadataResponse,
@@ -2508,7 +2508,7 @@ mod tests {
async fn test_rename_part_invalid_disk() { async fn test_rename_part_invalid_disk() {
let service = create_test_node_service(); let service = create_test_node_service();
let request = Request::new(RenamePartRequst { let request = Request::new(RenamePartRequest {
disk: "invalid-disk-path".to_string(), disk: "invalid-disk-path".to_string(),
src_volume: "src-volume".to_string(), src_volume: "src-volume".to_string(),
src_path: "src-path".to_string(), src_path: "src-path".to_string(),
@@ -2529,7 +2529,7 @@ mod tests {
async fn test_rename_file_invalid_disk() { async fn test_rename_file_invalid_disk() {
let service = create_test_node_service(); let service = create_test_node_service();
let request = Request::new(RenameFileRequst { let request = Request::new(RenameFileRequest {
disk: "invalid-disk-path".to_string(), disk: "invalid-disk-path".to_string(),
src_volume: "src-volume".to_string(), src_volume: "src-volume".to_string(),
src_path: "src-path".to_string(), src_path: "src-path".to_string(),