Skip to content

Commit

Permalink
fix: remove client recv msg limit fix: add enums to `types/__init__.p…
Browse files Browse the repository at this point in the history 
…y` (#60)

PiperOrigin-RevId: 347055288

Source-Author: Google APIs <[email protected]>
Source-Date: Fri Dec 11 12:44:37 2020 -0800
Source-Repo: googleapis/googleapis
Source-Sha: dd372aa22ded7a8ba6f0e03a80e06358a3fa0907
Source-Link: googleapis/googleapis@dd372aa

Co-authored-by: Bu Sun Kim <[email protected]>
  • Loading branch information
@yoshi-automation @busunkim96
yoshi-automation and busunkim96 authored Dec 28, 2020
1 parent ac3faf7 commit c6d7ae5
Show file tree
Hide file tree
Showing 11 changed files with 56 additions and 8 deletions.
1 change: 0 additions & 1 deletion ...cloud-container/google/cloud/container_v1/services/cluster_manager/transports/__init__.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,6 @@
_transport_registry["grpc"] = ClusterManagerGrpcTransport
_transport_registry["grpc_asyncio"] = ClusterManagerGrpcAsyncIOTransport


__all__ = (
"ClusterManagerTransport",
"ClusterManagerGrpcTransport",
Expand Down
10 changes: 9 additions & 1 deletion ...gle-cloud-container/google/cloud/container_v1/services/cluster_manager/transports/grpc.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -147,6 +147,10 @@ def __init__(
ssl_credentials=ssl_credentials,
scopes=scopes or self.AUTH_SCOPES,
quota_project_id=quota_project_id,
options=[
("grpc.max_send_message_length", -1),
("grpc.max_receive_message_length", -1),
],
)
self._ssl_channel_credentials = ssl_credentials
else:
Expand All @@ -165,6 +169,10 @@ def __init__(
ssl_credentials=ssl_channel_credentials,
scopes=scopes or self.AUTH_SCOPES,
quota_project_id=quota_project_id,
options=[
("grpc.max_send_message_length", -1),
("grpc.max_receive_message_length", -1),
],
)

self._stubs = {} # type: Dict[str, Callable]
Expand All @@ -191,7 +199,7 @@ def create_channel(
) -> grpc.Channel:
"""Create and return a gRPC channel object.
Args:
address (Optionsl[str]): The host for the channel to use.
address (Optional[str]): The host for the channel to use.
credentials (Optional[~.Credentials]): The
authorization credentials to attach to requests. These
credentials identify this application to the service. If
Expand Down
8 changes: 8 additions & 0 deletions ...d-container/google/cloud/container_v1/services/cluster_manager/transports/grpc_asyncio.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -192,6 +192,10 @@ def __init__(
ssl_credentials=ssl_credentials,
scopes=scopes or self.AUTH_SCOPES,
quota_project_id=quota_project_id,
options=[
("grpc.max_send_message_length", -1),
("grpc.max_receive_message_length", -1),
],
)
self._ssl_channel_credentials = ssl_credentials
else:
Expand All @@ -210,6 +214,10 @@ def __init__(
ssl_credentials=ssl_channel_credentials,
scopes=scopes or self.AUTH_SCOPES,
quota_project_id=quota_project_id,
options=[
("grpc.max_send_message_length", -1),
("grpc.max_receive_message_length", -1),
],
)

# Run the base constructor.
Expand Down
1 change: 0 additions & 1 deletion packages/google-cloud-container/google/cloud/container_v1/types/__init__.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -113,7 +113,6 @@
ShieldedNodes,
)


__all__ = (
"NodeConfig",
"ShieldedInstanceConfig",
Expand Down
1 change: 0 additions & 1 deletion ...-container/google/cloud/container_v1beta1/services/cluster_manager/transports/__init__.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,6 @@
_transport_registry["grpc"] = ClusterManagerGrpcTransport
_transport_registry["grpc_asyncio"] = ClusterManagerGrpcAsyncIOTransport


__all__ = (
"ClusterManagerTransport",
"ClusterManagerGrpcTransport",
Expand Down
10 changes: 9 additions & 1 deletion ...loud-container/google/cloud/container_v1beta1/services/cluster_manager/transports/grpc.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -147,6 +147,10 @@ def __init__(
ssl_credentials=ssl_credentials,
scopes=scopes or self.AUTH_SCOPES,
quota_project_id=quota_project_id,
options=[
("grpc.max_send_message_length", -1),
("grpc.max_receive_message_length", -1),
],
)
self._ssl_channel_credentials = ssl_credentials
else:
Expand All @@ -165,6 +169,10 @@ def __init__(
ssl_credentials=ssl_channel_credentials,
scopes=scopes or self.AUTH_SCOPES,
quota_project_id=quota_project_id,
options=[
("grpc.max_send_message_length", -1),
("grpc.max_receive_message_length", -1),
],
)

self._stubs = {} # type: Dict[str, Callable]
Expand All @@ -191,7 +199,7 @@ def create_channel(
) -> grpc.Channel:
"""Create and return a gRPC channel object.
Args:
address (Optionsl[str]): The host for the channel to use.
address (Optional[str]): The host for the channel to use.
credentials (Optional[~.Credentials]): The
authorization credentials to attach to requests. These
credentials identify this application to the service. If
Expand Down
8 changes: 8 additions & 0 deletions ...tainer/google/cloud/container_v1beta1/services/cluster_manager/transports/grpc_asyncio.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -192,6 +192,10 @@ def __init__(
ssl_credentials=ssl_credentials,
scopes=scopes or self.AUTH_SCOPES,
quota_project_id=quota_project_id,
options=[
("grpc.max_send_message_length", -1),
("grpc.max_receive_message_length", -1),
],
)
self._ssl_channel_credentials = ssl_credentials
else:
Expand All @@ -210,6 +214,10 @@ def __init__(
ssl_credentials=ssl_channel_credentials,
scopes=scopes or self.AUTH_SCOPES,
quota_project_id=quota_project_id,
options=[
("grpc.max_send_message_length", -1),
("grpc.max_receive_message_length", -1),
],
)

# Run the base constructor.
Expand Down
5 changes: 4 additions & 1 deletion packages/google-cloud-container/google/cloud/container_v1beta1/types/__init__.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -127,9 +127,10 @@
NotificationConfig,
ConfidentialNodes,
UpgradeEvent,
DatapathProvider,
UpgradeResourceType,
)


__all__ = (
"LinuxNodeConfig",
"NodeKubeletConfig",
Expand Down Expand Up @@ -242,4 +243,6 @@
"NotificationConfig",
"ConfidentialNodes",
"UpgradeEvent",
"DatapathProvider",
"UpgradeResourceType",
)
4 changes: 2 additions & 2 deletions packages/google-cloud-container/synth.metadata
View file
Original file line number Diff line number Diff line change
Expand Up @@ -11,8 +11,8 @@
"git": {
"name": "googleapis",
"remote": "https://github.com/googleapis/googleapis.git",
"sha": "df4fd38d040c5c8a0869936205bca13fb64b2cff",
"internalRef": "344443035"
"sha": "dd372aa22ded7a8ba6f0e03a80e06358a3fa0907",
"internalRef": "347055288"
}
},
{
Expand Down
8 changes: 8 additions & 0 deletions packages/google-cloud-container/tests/unit/gapic/container_v1/test_cluster_manager.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -9181,6 +9181,10 @@ def test_cluster_manager_transport_channel_mtls_with_client_cert_source(
scopes=("https://www.googleapis.com/auth/cloud-platform",),
ssl_credentials=mock_ssl_cred,
quota_project_id=None,
options=[
("grpc.max_send_message_length", -1),
("grpc.max_receive_message_length", -1),
],
)
assert transport.grpc_channel == mock_grpc_channel
assert transport._ssl_channel_credentials == mock_ssl_cred
Expand Down Expand Up @@ -9222,6 +9226,10 @@ def test_cluster_manager_transport_channel_mtls_with_adc(transport_class):
scopes=("https://www.googleapis.com/auth/cloud-platform",),
ssl_credentials=mock_ssl_cred,
quota_project_id=None,
options=[
("grpc.max_send_message_length", -1),
("grpc.max_receive_message_length", -1),
],
)
assert transport.grpc_channel == mock_grpc_channel

Expand Down
8 changes: 8 additions & 0 deletions packages/google-cloud-container/tests/unit/gapic/container_v1beta1/test_cluster_manager.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -9501,6 +9501,10 @@ def test_cluster_manager_transport_channel_mtls_with_client_cert_source(
scopes=("https://www.googleapis.com/auth/cloud-platform",),
ssl_credentials=mock_ssl_cred,
quota_project_id=None,
options=[
("grpc.max_send_message_length", -1),
("grpc.max_receive_message_length", -1),
],
)
assert transport.grpc_channel == mock_grpc_channel
assert transport._ssl_channel_credentials == mock_ssl_cred
Expand Down Expand Up @@ -9542,6 +9546,10 @@ def test_cluster_manager_transport_channel_mtls_with_adc(transport_class):
scopes=("https://www.googleapis.com/auth/cloud-platform",),
ssl_credentials=mock_ssl_cred,
quota_project_id=None,
options=[
("grpc.max_send_message_length", -1),
("grpc.max_receive_message_length", -1),
],
)
assert transport.grpc_channel == mock_grpc_channel

Expand Down

0 comments on commit c6d7ae5

Please sign in to comment.