This repository was archived by the owner on May 8, 2026. It is now read-only.
File tree Expand file tree Collapse file tree
google-cloud-bigtable/src
main/java/com/google/cloud/bigtable/gaxx/grpc
test/java/com/google/cloud/bigtable/gaxx/grpc Expand file tree Collapse file tree Original file line number Diff line number Diff line change 5151 *
5252 * <p>Internal API
5353 */
54- @ InternalApi ( "" )
54+ @ InternalApi
5555public class BigtableChannelPool extends ManagedChannel {
5656 @ VisibleForTesting
5757 static final Logger LOG = Logger .getLogger (BigtableChannelPool .class .getName ());
Original file line number Diff line number Diff line change 3030import java .util .concurrent .Executor ;
3131import java .util .concurrent .ScheduledExecutorService ;
3232
33- /** An instance of TransportChannelProvider that always provides the same TransportChannel. */
33+ /** An instance of TransportChannelProvider that provides a TransportChannel through a supplied InstantiatingGrpcChannelProvider . */
3434@ InternalApi
3535public final class BigtableTransportChannelProvider implements TransportChannelProvider {
3636
@@ -101,6 +101,7 @@ public TransportChannelProvider withPoolSize(int size) {
101101 return new BigtableTransportChannelProvider (newChannelProvider );
102102 }
103103
104+ /**Expected to only be called once when BigtableClientContext is created*/
104105 @ Override
105106 public TransportChannel getTransportChannel () throws IOException {
106107 // This provider's main purpose is to replace the default GAX ChannelPool
@@ -148,7 +149,7 @@ public TransportChannelProvider withCredentials(Credentials credentials) {
148149 return new BigtableTransportChannelProvider (newChannelProvider );
149150 }
150151
151- /** Creates a FixedTransportChannelProvider . */
152+ /** Creates a BigtableTransportChannelProvider . */
152153 public static BigtableTransportChannelProvider create (
153154 InstantiatingGrpcChannelProvider instantiatingGrpcChannelProvider ) {
154155 return new BigtableTransportChannelProvider (instantiatingGrpcChannelProvider );
Original file line number Diff line number Diff line change 99import java .util .Arrays ;
1010import java .util .Set ;
1111import java .util .stream .Collectors ;
12- import org .junit .Rule ;
1312import org .junit .Test ;
1413import org .junit .runner .RunWith ;
1514import org .junit .runners .JUnit4 ;
16- import org .mockito .junit .MockitoJUnit ;
17- import org .mockito .junit .MockitoRule ;
1815
1916@ RunWith (JUnit4 .class )
2017public class BigtableChannelPoolSettingsTest {
21- @ Rule public MockitoRule mockitoRule = MockitoJUnit .rule ();
2218
2319 @ Test
2420 public void testToBigtableChannelPoolSettingsAllFieldsSetCopiesCorrectly () throws Exception {
You can’t perform that action at this time.
0 commit comments