Package com.oracle.coherence.grpc.proxy

Class NettyGrpcAcceptorController

java.lang.Object
com.oracle.coherence.grpc.proxy.NettyGrpcAcceptorController
All Implemented Interfaces:
com.tangosol.net.grpc.GrpcAcceptorController, Comparable<com.tangosol.net.grpc.GrpcAcceptorController>
public class NettyGrpcAcceptorController extends Object implements com.tangosol.net.grpc.GrpcAcceptorController
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.
      Specified by:
      getPriority in interface com.tangosol.net.grpc.GrpcAcceptorController
      Returns:
      the priority of this controller if multiple controllers are discovered

    • 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

    • 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.
      Specified by:
      setDaemonPool in interface com.tangosol.net.grpc.GrpcAcceptorController
      Parameters:
      pool - the DaemonPool to be used

    • start

      public 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

    • stop

      public 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

    • 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

    • 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

    • getLocalPort

      public int getLocalPort()
      Description copied from interface: com.tangosol.net.grpc.GrpcAcceptorController
      Return the port that the gRPC server is listening on.
      Specified by:
      getLocalPort in interface com.tangosol.net.grpc.GrpcAcceptorController
      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.
      Specified by:
      getInProcessName in interface com.tangosol.net.grpc.GrpcAcceptorController
      Returns:
      the name of the in-process gRPC server

    • 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

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

    • createGrpcServices

      public static List<BindableGrpcProxyService> createGrpcServices()
      Obtain the list of gRPC proxy services to bind to a gRPC server.
      Returns:
      the list of gRPC proxy services to bind to a gRPC server

    • createGrpcServices

      public static List<BindableGrpcProxyService> createGrpcServices(GrpcServiceDependencies depsService)
      Obtain the list of gRPC proxy services to bind to a gRPC server.
      Parameters:
      depsService - the GrpcServiceDependencies to use
      Returns:
      the list of gRPC proxy services to bind to a gRPC server

    • configure

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