rename request/response in proto

coszio · coszio · commit 6e4eabf03201 · 2025-12-23T11:02:12.000-06:00
diff --git a/lib/api/src/grpc/proto/qdrant_internal_service.proto b/lib/api/src/grpc/proto/qdrant_internal_service.proto
@@ -14,9 +14,8 @@ service QdrantInternal {
   rpc WaitOnConsensusCommit(WaitOnConsensusCommitRequest)
       returns (WaitOnConsensusCommitResponse) {}
 
-  // Get telemetry from a peer
-  rpc GetPeerTelemetry(GetPeerTelemetryRequest)
-      returns (GetPeerTelemetryResponse) {}
+  // Get telemetry
+  rpc GetTelemetry(GetTelemetryRequest) returns (GetTelemetryResponse) {}
 }
 
 message GetConsensusCommitRequest {}
diff --git a/lib/api/src/grpc/proto/telemetry_internal.proto b/lib/api/src/grpc/proto/telemetry_internal.proto
@@ -5,16 +5,14 @@ import "collections.proto";
 package qdrant;
 option csharp_namespace = "Qdrant.Client.Grpc";
 
-message GetPeerTelemetryRequest {
-  // The peer id to ask for telemetry
-  uint64 peer_id = 1;
+message GetTelemetryRequest {
   // The level of detail needed
-  uint32 details_level = 2;
+  uint32 details_level = 1;
   // Timeout in secs for the request
-  uint64 timeout = 3;
+  uint64 timeout = 2;
 }
 
-message GetPeerTelemetryResponse {
+message GetTelemetryResponse {
   PeerTelemetry result = 1;
   double time = 2;
 }
diff --git a/lib/api/src/grpc/qdrant.rs b/lib/api/src/grpc/qdrant.rs
@@ -12449,7 +12449,7 @@ pub mod points_internal_server {
 #[derive(serde::Serialize)]
 #[allow(clippy::derive_partial_eq_without_eq)]
 #[derive(Clone, PartialEq, ::prost::Message)]
-pub struct GetPeerTelemetryRequest {
+pub struct GetTelemetryRequest {
     /// The level of detail needed
     #[prost(uint32, tag = "1")]
     pub details_level: u32,
@@ -12460,7 +12460,7 @@ pub struct GetPeerTelemetryRequest {
 #[derive(serde::Serialize)]
 #[allow(clippy::derive_partial_eq_without_eq)]
 #[derive(Clone, PartialEq, ::prost::Message)]
-pub struct GetPeerTelemetryResponse {
+pub struct GetTelemetryResponse {
     #[prost(message, optional, tag = "1")]
     pub result: ::core::option::Option<PeerTelemetry>,
     #[prost(double, tag = "2")]
@@ -12913,12 +12913,12 @@ pub mod qdrant_internal_client {
                 );
             self.inner.unary(req, path, codec).await
         }
-        /// Get telemetry from a peer
-        pub async fn get_peer_telemetry(
+        /// Get telemetry
+        pub async fn get_telemetry(
             &mut self,
-            request: impl tonic::IntoRequest<super::GetPeerTelemetryRequest>,
+            request: impl tonic::IntoRequest<super::GetTelemetryRequest>,
         ) -> std::result::Result<
-            tonic::Response<super::GetPeerTelemetryResponse>,
+            tonic::Response<super::GetTelemetryResponse>,
             tonic::Status,
         > {
             self.inner
@@ -12932,11 +12932,11 @@ pub mod qdrant_internal_client {
                 })?;
             let codec = tonic::codec::ProstCodec::default();
             let path = http::uri::PathAndQuery::from_static(
-                "/qdrant.QdrantInternal/GetPeerTelemetry",
+                "/qdrant.QdrantInternal/GetTelemetry",
             );
             let mut req = request.into_request();
             req.extensions_mut()
-                .insert(GrpcMethod::new("qdrant.QdrantInternal", "GetPeerTelemetry"));
+                .insert(GrpcMethod::new("qdrant.QdrantInternal", "GetTelemetry"));
             self.inner.unary(req, path, codec).await
         }
     }
@@ -12964,12 +12964,12 @@ pub mod qdrant_internal_server {
             tonic::Response<super::WaitOnConsensusCommitResponse>,
             tonic::Status,
         >;
-        /// Get telemetry from a peer
-        async fn get_peer_telemetry(
+        /// Get telemetry
+        async fn get_telemetry(
             &self,
-            request: tonic::Request<super::GetPeerTelemetryRequest>,
+            request: tonic::Request<super::GetTelemetryRequest>,
         ) -> std::result::Result<
-            tonic::Response<super::GetPeerTelemetryResponse>,
+            tonic::Response<super::GetTelemetryResponse>,
             tonic::Status,
         >;
     }
@@ -13149,26 +13149,25 @@ pub mod qdrant_internal_server {
                     };
                     Box::pin(fut)
                 }
-                "/qdrant.QdrantInternal/GetPeerTelemetry" => {
+                "/qdrant.QdrantInternal/GetTelemetry" => {
                     #[allow(non_camel_case_types)]
-                    struct GetPeerTelemetrySvc<T: QdrantInternal>(pub Arc<T>);
+                    struct GetTelemetrySvc<T: QdrantInternal>(pub Arc<T>);
                     impl<
                         T: QdrantInternal,
-                    > tonic::server::UnaryService<super::GetPeerTelemetryRequest>
-                    for GetPeerTelemetrySvc<T> {
-                        type Response = super::GetPeerTelemetryResponse;
+                    > tonic::server::UnaryService<super::GetTelemetryRequest>
+                    for GetTelemetrySvc<T> {
+                        type Response = super::GetTelemetryResponse;
                         type Future = BoxFuture<
                             tonic::Response<Self::Response>,
                             tonic::Status,
                         >;
                         fn call(
                             &mut self,
-                            request: tonic::Request<super::GetPeerTelemetryRequest>,
+                            request: tonic::Request<super::GetTelemetryRequest>,
                         ) -> Self::Future {
                             let inner = Arc::clone(&self.0);
                             let fut = async move {
-                                <T as QdrantInternal>::get_peer_telemetry(&inner, request)
-                                    .await
+                                <T as QdrantInternal>::get_telemetry(&inner, request).await
                             };
                             Box::pin(fut)
                         }
@@ -13180,7 +13179,7 @@ pub mod qdrant_internal_server {
                     let inner = self.inner.clone();
                     let fut = async move {
                         let inner = inner.0;
-                        let method = GetPeerTelemetrySvc(inner);
+                        let method = GetTelemetrySvc(inner);
                         let codec = tonic::codec::ProstCodec::default();
                         let mut grpc = tonic::server::Grpc::new(codec)
                             .apply_compression_config(
diff --git a/src/tonic/api/qdrant_internal_api.rs b/src/tonic/api/qdrant_internal_api.rs
@@ -3,8 +3,8 @@ use std::time::{Duration, Instant};
 
 use api::grpc::qdrant_internal_server::QdrantInternal;
 use api::grpc::{
-    GetConsensusCommitRequest, GetConsensusCommitResponse, GetPeerTelemetryRequest,
-    GetPeerTelemetryResponse, PeerTelemetry, WaitOnConsensusCommitRequest,
+    GetConsensusCommitRequest, GetConsensusCommitResponse, GetTelemetryRequest,
+    GetTelemetryResponse, PeerTelemetry, WaitOnConsensusCommitRequest,
     WaitOnConsensusCommitResponse,
 };
 use common::types::{DetailsLevel, TelemetryDetail};
@@ -68,10 +68,10 @@ impl QdrantInternal for QdrantInternalService {
         Ok(Response::new(WaitOnConsensusCommitResponse { ok }))
     }
 
-    async fn get_peer_telemetry(
+    async fn get_telemetry(
         &self,
-        request: Request<GetPeerTelemetryRequest>,
-    ) -> Result<Response<GetPeerTelemetryResponse>, Status> {
+        request: Request<GetTelemetryRequest>,
+    ) -> Result<Response<GetTelemetryResponse>, Status> {
         let request = request.into_inner();
 
         if request.details_level < 2 {
@@ -97,7 +97,7 @@ impl QdrantInternal for QdrantInternalService {
             .prepare_data(&access, detail, Some(timeout))
             .await?;
 
-        let response = GetPeerTelemetryResponse {
+        let response = GetTelemetryResponse {
             result: Some(PeerTelemetry::try_from(telemetry_data)?),
             time: timing.elapsed().as_secs_f64(),
         };
