Skip to content
This repository was archived by the owner on Apr 1, 2026. It is now read-only.

Commit f9a1907

Browse files
daniel-sanchedaniel-sanche
authored
feat: add pooled grpc transport (#748)
1 parent c55099f commit f9a1907

10 files changed

Lines changed: 2207 additions & 30 deletions

File tree

‎.gitmodules‎

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
[submodule "gapic-generator-fork"]
2+
path = gapic-generator-fork
3+
url = git@github.com:googleapis/gapic-generator-python.git

‎gapic-generator-fork‎

Submodule gapic-generator-fork added at b26cda7

‎google/cloud/bigtable/client.py‎

Lines changed: 299 additions & 26 deletions
Large diffs are not rendered by default.

‎google/cloud/bigtable_v2/services/bigtable/client.py‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -53,6 +53,7 @@
5353
from .transports.base import BigtableTransport, DEFAULT_CLIENT_INFO
5454
from .transports.grpc import BigtableGrpcTransport
5555
from .transports.grpc_asyncio import BigtableGrpcAsyncIOTransport
56+
from .transports.pooled_grpc_asyncio import PooledBigtableGrpcAsyncIOTransport
5657
from .transports.rest import BigtableRestTransport
5758

5859

@@ -67,6 +68,7 @@ class BigtableClientMeta(type):
6768
_transport_registry = OrderedDict() # type: Dict[str, Type[BigtableTransport]]
6869
_transport_registry["grpc"] = BigtableGrpcTransport
6970
_transport_registry["grpc_asyncio"] = BigtableGrpcAsyncIOTransport
71+
_transport_registry["pooled_grpc_asyncio"] = PooledBigtableGrpcAsyncIOTransport
7072
_transport_registry["rest"] = BigtableRestTransport
7173

7274
def get_transport_class(

‎google/cloud/bigtable_v2/services/bigtable/transports/__init__.py‎

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@
1919
from .base import BigtableTransport
2020
from .grpc import BigtableGrpcTransport
2121
from .grpc_asyncio import BigtableGrpcAsyncIOTransport
22+
from .pooled_grpc_asyncio import PooledBigtableGrpcAsyncIOTransport
2223
from .rest import BigtableRestTransport
2324
from .rest import BigtableRestInterceptor
2425

@@ -27,12 +28,14 @@
2728
_transport_registry = OrderedDict() # type: Dict[str, Type[BigtableTransport]]
2829
_transport_registry["grpc"] = BigtableGrpcTransport
2930
_transport_registry["grpc_asyncio"] = BigtableGrpcAsyncIOTransport
31+
_transport_registry["pooled_grpc_asyncio"] = PooledBigtableGrpcAsyncIOTransport
3032
_transport_registry["rest"] = BigtableRestTransport
3133

3234
__all__ = (
3335
"BigtableTransport",
3436
"BigtableGrpcTransport",
3537
"BigtableGrpcAsyncIOTransport",
38+
"PooledBigtableGrpcAsyncIOTransport",
3639
"BigtableRestTransport",
3740
"BigtableRestInterceptor",
3841
)

0 commit comments

Comments
 (0)