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 BaseGrpcAcceptorController
The default GrpcAcceptorController implementation.
Since:
22.06.2
Author:
Jonathan Knight 2022.08.25

  • 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 GrpcServiceDependencies createServiceDeps()
      Specified by:
      createServiceDeps in class BaseGrpcAcceptorController

    • startInternal

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

    • stopInternal

      protected void stopInternal()
      Specified by:
      stopInternal in class 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)