ChannelPool (Cloud Bigtable HBase Client for Java 1.12.0 API)

com.google.cloud.bigtable.grpc.io

Class ChannelPool

  • java.lang.Object
    • io.grpc.Channel
      • io.grpc.ManagedChannel
        • com.google.cloud.bigtable.grpc.io.ChannelPool


  • public class ChannelPool
    extends io.grpc.ManagedChannel
    Manages a set of ClosableChannels and uses them in a round robin.
    Version:
    $Id: $Id
    Author:
    sduskis
    • Field Detail

      • LOG

        protected static final Logger LOG
        Constant LOG
      • STATS

        protected static com.google.cloud.bigtable.grpc.io.ChannelPool.Stats STATS
    • Method Detail

      • extractIdentifier

        public static final String extractIdentifier(io.grpc.Metadata trailers)
      • getStats

        protected static com.google.cloud.bigtable.grpc.io.ChannelPool.Stats getStats()
      • authority

        public String authority()
        Specified by:
        authority in class io.grpc.Channel
      • newCall

        public <ReqT,RespT> io.grpc.ClientCall<ReqT,RespT> newCall(io.grpc.MethodDescriptor<ReqT,RespT> methodDescriptor,
                                                                   io.grpc.CallOptions callOptions)

        Create a ClientCall on a Channel from the pool chosen in a round-robin fashion to the remote operation specified by the given MethodDescriptor. The returned ClientCall does not trigger any remote behavior until ClientCall.start(ClientCall.Listener, io.grpc.Metadata) is invoked.

        Specified by:
        newCall in class io.grpc.Channel
      • size

        public int size()
        size.
        Returns:
        a int.
      • shutdown

        public io.grpc.ManagedChannel shutdown()
        Specified by:
        shutdown in class io.grpc.ManagedChannel
      • isShutdown

        public boolean isShutdown()
        Specified by:
        isShutdown in class io.grpc.ManagedChannel
      • isTerminated

        public boolean isTerminated()
        Specified by:
        isTerminated in class io.grpc.ManagedChannel
      • shutdownNow

        public io.grpc.ManagedChannel shutdownNow()
        Specified by:
        shutdownNow in class io.grpc.ManagedChannel