From b8d88d247beb84e593d73bdc24fab93a7d01be72 Mon Sep 17 00:00:00 2001 From: Finn Carroll Date: Fri, 15 Nov 2024 11:16:36 -0800 Subject: [PATCH] Remove streaming endpoint for NodesInfoService Signed-off-by: Finn Carroll --- .../grpc/services/nodesInfo/NodesInfoServiceImpl.java | 9 +-------- .../admin/cluster/node/info/NodesInfoService.proto | 1 - 2 files changed, 1 insertion(+), 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 index 4db1264e8b5c9..fb037aff74cae 100644 --- 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 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 index 69cd2b65a909d..3ff076f33d6e4 100644 --- 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) {} }