ChannelPool (Cloud Bigtable HBase Client for Java 1.12.0 API)

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

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

static interface ChannelPool.ChannelFactory
A factory for creating ManagedChannels to be used in a ChannelPool.

Field Summary

Fields
Modifier and Type Field and Description

protected static Logger LOG
Constant LOG

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

Constructor Summary

Constructors
Constructor and Description

ChannelPool(ChannelPool.ChannelFactory factory, int count)
Constructor for ChannelPool.

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`String`	`authority()`
`boolean`	`awaitTermination(long timeout, TimeUnit unit)`
`static String`	`extractIdentifier(io.grpc.Metadata trailers)`
`protected static com.google.cloud.bigtable.grpc.io.ChannelPool.Stats`	`getStats()`
`boolean`	`isShutdown()`
`boolean`	`isTerminated()`
`<ReqT,RespT> io.grpc.ClientCall<ReqT,RespT>`	`newCall(io.grpc.MethodDescriptor<ReqT,RespT> methodDescriptor, io.grpc.CallOptions callOptions)`
`io.grpc.ManagedChannel`	`shutdown()`
`io.grpc.ManagedChannel`	`shutdownNow()`
`int`	`size()` size.

Methods inherited from class io.grpc.ManagedChannel
enterIdle, getState, notifyWhenStateChanged, resetConnectBackoff

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOG
```
protected static final Logger LOG
```
Constant LOG

STATS

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

Constructor Detail
- ChannelPool
```
public ChannelPool(ChannelPool.ChannelFactory factory,
                   int count)
            throws IOException
```
  Constructor for ChannelPool.
  
  Parameters:
  
  factory - a ChannelPool.ChannelFactory object.
  
  Throws:
  
  IOException - if any.

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
- awaitTermination
```
public boolean awaitTermination(long timeout,
                                TimeUnit unit)
                         throws InterruptedException
```
  Specified by:
  
  awaitTermination in class io.grpc.ManagedChannel
  
  Throws:
  
  InterruptedException

Except as otherwise noted, the content of this page is licensed under the Creative Commons Attribution 4.0 License, and code samples are licensed under the Apache 2.0 License. For details, see the Google Developers Site Policies. Java is a registered trademark of Oracle and/or its affiliates.

Last updated 2024-02-15 UTC.

Modifier and Type	Field and Description
`protected static Logger`	`LOG` Constant `LOG`
`protected static com.google.cloud.bigtable.grpc.io.ChannelPool.Stats`	`STATS`

ChannelPool (Cloud Bigtable HBase Client for Java 1.12.0 API)

Class ChannelPool

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class io.grpc.ManagedChannel

Methods inherited from class java.lang.Object

Field Detail

LOG

STATS

Constructor Detail

ChannelPool

Method Detail

extractIdentifier

getStats

authority

newCall

size

shutdown

isShutdown

isTerminated

shutdownNow

awaitTermination