Package cz.o2.proxima.direct.server

Class IngestServer

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

    • 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.

      • onClose

        protected void onClose()

      • createServer

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

      • getServices

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

      • getExecutor

        public java.util.concurrent.Executor getExecutor()

      • getScheduler

        public java.util.concurrent.ScheduledExecutorService getScheduler()

      • getCfg

        public cz.o2.proxima.typesafe.config.Config getCfg()

      • isIgnoreErrors

        public boolean isIgnoreErrors()

      • getRetryPolicy

        public dev.failsafe.RetryPolicy<java.lang.Void> getRetryPolicy()