Package com.oracle.coherence.grpc.proxy

Class NettyGrpcAcceptorController

java.lang.Object
com.oracle.coherence.grpc.proxy.common.BaseGrpcAcceptorController
com.oracle.coherence.grpc.proxy.NettyGrpcAcceptorController
All Implemented Interfaces:
com.tangosol.net.grpc.GrpcAcceptorController, Comparable<com.tangosol.net.grpc.GrpcAcceptorController>
public class NettyGrpcAcceptorController extends com.oracle.coherence.grpc.proxy.common.BaseGrpcAcceptorController
The default GrpcAcceptorController implementation.
Since:
22.06.2
Author:
Jonathan Knight 2022.08.25

  • Field Summary

    Fields inherited from class com.oracle.coherence.grpc.proxy.common.BaseGrpcAcceptorController

    m_dependencies

    Fields inherited from interface com.tangosol.net.grpc.GrpcAcceptorController

    NULL_CONTROLLER, PRIORITY_NORMAL

  • Constructor Summary

    Constructors
    Constructor
    Description
    NettyGrpcAcceptorController()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
    configure(io.grpc.ServerBuilder<?> serverBuilder, io.grpc.inprocess.InProcessServerBuilder inProcessServerBuilder)
     
    protected io.grpc.inprocess.InProcessServerBuilder
    createInProcessServerBuilder(com.tangosol.internal.net.service.peer.acceptor.GrpcAcceptorDependencies deps)
     
    protected io.grpc.ServerBuilder<?>
    createServerBuilder(com.tangosol.internal.net.service.peer.acceptor.GrpcAcceptorDependencies deps)
     
    protected com.oracle.coherence.grpc.proxy.common.GrpcServiceDependencies
    createServiceDeps(com.oracle.coherence.grpc.proxy.common.GrpcServiceDependencies defaultDeps)
     
    String
    getInProcessName()
    Return the name of the in-process gRPC server.
    int
    getLocalPort()
    Return the port that the gRPC server is listening on.
    int
    getPriority()
    Return the priority of this controller if multiple controllers are discovered.
    com.tangosol.net.grpc.GrpcDependencies.ServerType
    getServerType()
     
    void
    setDaemonPool(com.tangosol.internal.util.DaemonPool pool)
    Set the DaemonPool to be used.
    protected void
    startInternal(List<io.grpc.ServerServiceDefinition> listServices, List<io.grpc.BindableService> listBindable)
     
    protected void
    stopInternal()
     

    Methods inherited from class com.oracle.coherence.grpc.proxy.common.BaseGrpcAcceptorController

    applyInterceptors, ensureServices, getBindableServices, getDependencies, getLocalAddress, getProxyService, isRunning, setAcceptor, setDependencies, start, stop

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface com.tangosol.net.grpc.GrpcAcceptorController

    compareTo

  • Constructor Details

    • NettyGrpcAcceptorController

      public NettyGrpcAcceptorController()

  • Method Details

    • getPriority

      public int getPriority()
      Description copied from interface: com.tangosol.net.grpc.GrpcAcceptorController
      Return the priority of this controller if multiple controllers are discovered. The controller with the highest priority will be used. If multiple controllers have the highest priority the actual controller used cannot be determined.
      Returns:
      the priority of this controller if multiple controllers are discovered

    • setDaemonPool

      public void setDaemonPool(com.tangosol.internal.util.DaemonPool pool)
      Description copied from interface: com.tangosol.net.grpc.GrpcAcceptorController
      Set the DaemonPool to be used.
      Parameters:
      pool - the DaemonPool to be used

    • createServiceDeps

      protected com.oracle.coherence.grpc.proxy.common.GrpcServiceDependencies createServiceDeps(com.oracle.coherence.grpc.proxy.common.GrpcServiceDependencies defaultDeps)
      Specified by:
      createServiceDeps in class com.oracle.coherence.grpc.proxy.common.BaseGrpcAcceptorController

    • startInternal

      protected void startInternal(List<io.grpc.ServerServiceDefinition> listServices, List<io.grpc.BindableService> listBindable) throws IOException
      Specified by:
      startInternal in class com.oracle.coherence.grpc.proxy.common.BaseGrpcAcceptorController
      Throws:
      IOException

    • stopInternal

      protected void stopInternal()
      Specified by:
      stopInternal in class com.oracle.coherence.grpc.proxy.common.BaseGrpcAcceptorController

    • getLocalPort

      public int getLocalPort()
      Description copied from interface: com.tangosol.net.grpc.GrpcAcceptorController
      Return the port that the gRPC server is listening on.
      Returns:
      the port that the gRPC server is listening on

    • getInProcessName

      public String getInProcessName()
      Description copied from interface: com.tangosol.net.grpc.GrpcAcceptorController
      Return the name of the in-process gRPC server.
      Returns:
      the name of the in-process gRPC server

    • getServerType

      public com.tangosol.net.grpc.GrpcDependencies.ServerType getServerType()

    • createServerBuilder

      protected io.grpc.ServerBuilder<?> createServerBuilder(com.tangosol.internal.net.service.peer.acceptor.GrpcAcceptorDependencies deps)

    • createInProcessServerBuilder

      protected io.grpc.inprocess.InProcessServerBuilder createInProcessServerBuilder(com.tangosol.internal.net.service.peer.acceptor.GrpcAcceptorDependencies deps)

    • configure

      protected void configure(io.grpc.ServerBuilder<?> serverBuilder, io.grpc.inprocess.InProcessServerBuilder inProcessServerBuilder)