From e9850433ca404ce93fd655386c0f938ab95926fd Mon Sep 17 00:00:00 2001 From: Finn Carroll Date: Fri, 15 Nov 2024 15:32:46 -0800 Subject: [PATCH] Pre-emptively add Search+Document services to GrpcServiceRegistry. Signed-off-by: Finn Carroll --- server/src/main/java/org/opensearch/node/Node.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/server/src/main/java/org/opensearch/node/Node.java b/server/src/main/java/org/opensearch/node/Node.java index 209ee894239d5..7ed72328df9c9 100644 --- a/server/src/main/java/org/opensearch/node/Node.java +++ b/server/src/main/java/org/opensearch/node/Node.java @@ -146,8 +146,10 @@ import org.opensearch.gateway.remote.RemoteClusterStateCleanupManager; import org.opensearch.gateway.remote.RemoteClusterStateService; import org.opensearch.grpc.GrpcServerTransport; +import org.opensearch.grpc.services.DocumentServiceImpl; import org.opensearch.grpc.services.GrpcServiceRegistry; import org.opensearch.grpc.services.NodesInfoServiceImpl; +import org.opensearch.grpc.services.SearchServiceImpl; import org.opensearch.http.HttpServerTransport; import org.opensearch.identity.IdentityService; import org.opensearch.index.IndexModule; @@ -1137,8 +1139,9 @@ protected Node( ); GrpcServiceRegistry grpcReg = new GrpcServiceRegistry( + new SearchServiceImpl(client), + new DocumentServiceImpl(client), new NodesInfoServiceImpl(client) - // TODO: Other service stubs here ); final NetworkModule networkModule = new NetworkModule(