Package com.oracle.coherence.grpc.proxy.common

Class BaseGrpcAcceptorController

java.lang.Object
com.oracle.coherence.grpc.proxy.common.BaseGrpcAcceptorController
All Implemented Interfaces:
com.tangosol.net.grpc.GrpcAcceptorController, Comparable<com.tangosol.net.grpc.GrpcAcceptorController>
Direct Known Subclasses:
HelidonGrpcAcceptorController, NettyGrpcAcceptorController
public abstract class BaseGrpcAcceptorController extends Object implements com.tangosol.net.grpc.GrpcAcceptorController
A base implementation of a GrpcAcceptorController.

  • Field Details

    • m_dependencies

      protected com.tangosol.internal.net.service.peer.acceptor.GrpcAcceptorDependencies m_dependencies
      The dependencies to use to configure the server.

  • Constructor Details

    • BaseGrpcAcceptorController

      public BaseGrpcAcceptorController()

  • Method Details

    • start

      public final void start()
      Description copied from interface: com.tangosol.net.grpc.GrpcAcceptorController
      Start the gRPC server.
      Specified by:
      start in interface com.tangosol.net.grpc.GrpcAcceptorController

    • createServiceDeps

      protected abstract GrpcServiceDependencies createServiceDeps()

    • startInternal

      protected abstract void startInternal(List<io.grpc.ServerServiceDefinition> listService, List<io.grpc.BindableService> listBindable) throws IOException
      Throws:
      IOException

    • stop

      public final void stop()
      Description copied from interface: com.tangosol.net.grpc.GrpcAcceptorController
      Stop the gRPC server.
      Specified by:
      stop in interface com.tangosol.net.grpc.GrpcAcceptorController

    • stopInternal

      protected abstract void stopInternal()

    • isRunning

      public boolean isRunning()
      Description copied from interface: com.tangosol.net.grpc.GrpcAcceptorController
      Returns true if the gRPC server is running.
      Specified by:
      isRunning in interface com.tangosol.net.grpc.GrpcAcceptorController
      Returns:
      true if the gRPC server is running

    • setDependencies

      public void setDependencies(com.tangosol.internal.net.service.peer.acceptor.GrpcAcceptorDependencies deps)
      Description copied from interface: com.tangosol.net.grpc.GrpcAcceptorController
      Set the GrpcAcceptorDependencies.
      Specified by:
      setDependencies in interface com.tangosol.net.grpc.GrpcAcceptorController
      Parameters:
      deps - the GrpcAcceptorDependencies

    • getDependencies

      public com.tangosol.internal.net.service.peer.acceptor.GrpcAcceptorDependencies getDependencies()
      Description copied from interface: com.tangosol.net.grpc.GrpcAcceptorController
      Returns the gRPC acceptor dependencies.
      Specified by:
      getDependencies in interface com.tangosol.net.grpc.GrpcAcceptorController
      Returns:
      the gRPC acceptor dependencies

    • getLocalAddress

      public String getLocalAddress()
      Description copied from interface: com.tangosol.net.grpc.GrpcAcceptorController
      Return the address that the gRPC server is listening on.
      Specified by:
      getLocalAddress in interface com.tangosol.net.grpc.GrpcAcceptorController
      Returns:
      the address that the gRPC server is listening on

    • getBindableServices

      public List<BindableGrpcProxyService> getBindableServices()
      Return the list of services this controller is serving.
      Specified by:
      getBindableServices in interface com.tangosol.net.grpc.GrpcAcceptorController
      Returns:
      the list of services this controller is serving

    • ensureServices

      protected List<io.grpc.ServerServiceDefinition> ensureServices(GrpcServiceDependencies serviceDeps)

    • applyInterceptors

      protected io.grpc.ServerServiceDefinition applyInterceptors(BindableGrpcProxyService service)