Remove streaming endpoint for NodesInfoService

Signed-off-by: Finn Carroll <[email protected]>
finnegancarroll · Nov 23, 2024 · 14bdb4c · 14bdb4c
1 parent 6e5ea5b
commit 14bdb4c
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) {}
 }