Start grpc server

Signed-off-by: Finn Carroll <carrofin@amazon.com>
finnegancarroll · Oct 29, 2024 · c1a0a2d · c1a0a2d
1 parent cc33591
commit c1a0a2d
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 10 deletions.
diff --git a/server/src/main/java/org/opensearch/grpc/AbstractGrpcServerTransport.java b/server/src/main/java/org/opensearch/grpc/AbstractGrpcServerTransport.java
@@ -49,26 +49,19 @@ public abstract class AbstractGrpcServerTransport extends AbstractLifecycleCompo
 
     @Override
     public BoundTransportAddress boundAddress() {
+        // TODO: BOUND ADDR GETTER
         return null;
     }
 
     @Override
     public GrpcInfo info() {
+        // TODO: IMPLE FETCH GRPC INFO
         return null;
     }
 
     @Override
     public GrpcStats stats() {
+        // TODO: IMPL FETCH GRPC STATS
         return null;
     }
-
-    @Override
-    protected void doStop() {
-
-    }
-
-    @Override
-    protected void doClose() {
-
-    }
 }
diff --git a/server/src/main/java/org/opensearch/node/Node.java b/server/src/main/java/org/opensearch/node/Node.java
@@ -1753,11 +1753,16 @@ public void onTimeout(TimeValue timeout) {
 
         injector.getInstance(HttpServerTransport.class).start();
 
+        // TODO: FEATURE FLAG HERE?
+        injector.getInstance(GrpcServerTransport.class).start();
+
         if (WRITE_PORTS_FILE_SETTING.get(settings())) {
             TransportService transport = injector.getInstance(TransportService.class);
             writePortsFile("transport", transport.boundAddress());
             HttpServerTransport http = injector.getInstance(HttpServerTransport.class);
             writePortsFile("http", http.boundAddress());
+            GrpcServerTransport grpc = injector.getInstance(GrpcServerTransport.class);
+            writePortsFile("grpc", grpc.boundAddress());
         }
 
         logger.info("started");