Remove streaming endpoint for NodesInfoService

Signed-off-by: Finn Carroll <[email protected]>
opensearch-project · Nov 15, 2024 · b8d88d2 · b8d88d2
1 parent 26e8e1a
commit b8d88d2
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 9 deletions.
diff --git a/server/src/main/java/org/opensearch/grpc/services/nodesInfo/NodesInfoServiceImpl.java b/server/src/main/java/org/opensearch/grpc/services/nodesInfo/NodesInfoServiceImpl.java
@@ -57,14 +57,7 @@ public void getNodesInfo(NodesInfoProtoService.NodesInfoRequestProto request, St
         responseObserver.onNext(respToProto(response));
         responseObserver.onCompleted();
     }
-
-    @Override
-    public void streamNodesInfo(NodesInfoProtoService.NodesInfoRequestProto request, StreamObserver<NodesInfoProtoService.NodesInfoResponseProto> responseObserver) {
-        responseObserver.onError(
-            Status.UNIMPLEMENTED.withDescription("Method StreamNodesInfo is not implemented").asRuntimeException()
-        );
-    }
-
+
     private static NodesInfoRequest reqFromProto(NodesInfoProtoService.NodesInfoRequestProto request) {
         String[] nodeIds = request.getNodeIdsList().toArray(new String[0]);
         NodesInfoRequest nodesInfoRequest = new NodesInfoRequest(nodeIds);

diff --git a/server/src/main/proto/org/opensearch/action/admin/cluster/node/info/NodesInfoService.proto b/server/src/main/proto/org/opensearch/action/admin/cluster/node/info/NodesInfoService.proto
@@ -38,5 +38,4 @@ message NodesInfoResponseProto {
 
 service NodesInfoService {
   rpc GetNodesInfo(NodesInfoRequestProto) returns (NodesInfoResponseProto) {}
-  rpc StreamNodesInfo(NodesInfoRequestProto) returns (stream NodesInfoResponseProto) {}
 }