Package cz.o2.proxima.direct.server

Class IngestServer

  • public class IngestServer
extends java.lang.Object
    The ingestion server.

    • Constructor Summary

      Constructors 
      Modifier Constructor Description
      protected IngestServer​(cz.o2.proxima.typesafe.config.Config cfg)  
      protected IngestServer​(cz.o2.proxima.typesafe.config.Config cfg, Repository repo)  

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected java.util.concurrent.Executor createExecutor​(cz.o2.proxima.typesafe.config.Config cfg)  
      protected io.grpc.Server createServer​(int port, boolean debug)  
      protected static cz.o2.proxima.typesafe.config.Config getCfgFromArgs​(java.lang.String[] args)  
      protected java.lang.Iterable<io.grpc.BindableService> getServices()  
      static void main​(java.lang.String[] args)
      Run the server.
      protected void run()
      Run the server.
      protected static void runWithServerFactory​(Factory<? extends IngestServer> serverFactory)  

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Constructor Detail

      • IngestServer

        protected IngestServer​(cz.o2.proxima.typesafe.config.Config cfg)

      • IngestServer

        protected IngestServer​(cz.o2.proxima.typesafe.config.Config cfg,
                       Repository repo)

    • Method Detail

      • main

        public static void main​(java.lang.String[] args)
                 throws java.lang.Throwable
        Run the server.
        Parameters:
        args - command line arguments
        Throws:
        java.lang.Throwable - on error

      • getCfgFromArgs

        protected static cz.o2.proxima.typesafe.config.Config getCfgFromArgs​(java.lang.String[] args)

      • runWithServerFactory

        protected static void runWithServerFactory​(Factory<? extends IngestServer> serverFactory)

      • createExecutor

        protected java.util.concurrent.Executor createExecutor​(cz.o2.proxima.typesafe.config.Config cfg)

      • run

        protected void run()
        Run the server.

      • createServer

        protected io.grpc.Server createServer​(int port,
                                      boolean debug)

      • getServices

        protected java.lang.Iterable<io.grpc.BindableService> getServices()