Skip to content

Commit a9d60f4

Browse files
gcf-owl-bot[bot]ohmayr
gcf-owl-bot[bot]
and
ohmayr
authored
feat: [google-cloud-managedkafka] Add support for opt-in debug logging (#13321)
BEGIN_COMMIT_OVERRIDE feat: Add support for opt-in debug logging fix: Fix typing issue with gRPC metadata when key ends in -bin chore: Update gapic-generator-python to v1.21.0 feat: A new field `satisfies_pzi` is added to message `.google.cloud.managedkafka.v1.Cluster` feat: A new field `satisfies_pzs` is added to message `.google.cloud.managedkafka.v1.Cluster` END_COMMIT_OVERRIDE - [ ] Regenerate this pull request now. fix: Fix typing issue with gRPC metadata when key ends in -bin chore: Update gapic-generator-python to v1.21.0 PiperOrigin-RevId: 705285820 Source-Link: googleapis/googleapis@f9b8b91 Source-Link: googleapis/googleapis-gen@ca1e0a1 Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLW1hbmFnZWRrYWZrYS8uT3dsQm90LnlhbWwiLCJoIjoiY2ExZTBhMWU0NzJkNmU2ZjVkZTg4M2E1Y2I1NDcyNGYxMTJjZTM0OCJ9 BEGIN_NESTED_COMMIT feat: [google-cloud-managedkafka] A new field `satisfies_pzi` is added to message `.google.cloud.managedkafka.v1.Cluster` feat: A new field `satisfies_pzs` is added to message `.google.cloud.managedkafka.v1.Cluster` PiperOrigin-RevId: 702413947 Source-Link: googleapis/googleapis@b56dbf5 Source-Link: googleapis/googleapis-gen@52ade12 Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLW1hbmFnZWRrYWZrYS8uT3dsQm90LnlhbWwiLCJoIjoiNTJhZGUxMjc0YjkwYTRkZWQ5ZWFiYTRkZTQzMWEwYTA2OTY1ZDk5ZiJ9 END_NESTED_COMMIT --------- Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com> Co-authored-by: ohmayr <omairnaveed@ymail.com>
1 parent e188f1a commit a9d60f4

11 files changed

Lines changed: 1770 additions & 316 deletions

File tree

‎packages/google-cloud-managedkafka/google/cloud/managedkafka/gapic_version.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,4 +13,4 @@
1313
# See the License for the specific language governing permissions and
1414
# limitations under the License.
1515
#
16-
__version__ = "0.1.5" # {x-release-please-version}
16+
__version__ = "0.0.0" # {x-release-please-version}

‎packages/google-cloud-managedkafka/google/cloud/managedkafka_v1/gapic_version.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,4 +13,4 @@
1313
# See the License for the specific language governing permissions and
1414
# limitations under the License.
1515
#
16-
__version__ = "0.1.5" # {x-release-please-version}
16+
__version__ = "0.0.0" # {x-release-please-version}

‎packages/google-cloud-managedkafka/google/cloud/managedkafka_v1/services/managed_kafka/async_client.py‎

Lines changed: 132 additions & 60 deletions
Large diffs are not rendered by default.

‎packages/google-cloud-managedkafka/google/cloud/managedkafka_v1/services/managed_kafka/client.py‎

Lines changed: 137 additions & 60 deletions
Large diffs are not rendered by default.

‎packages/google-cloud-managedkafka/google/cloud/managedkafka_v1/services/managed_kafka/pagers.py‎

Lines changed: 30 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -67,7 +67,7 @@ def __init__(
6767
*,
6868
retry: OptionalRetry = gapic_v1.method.DEFAULT,
6969
timeout: Union[float, object] = gapic_v1.method.DEFAULT,
70-
metadata: Sequence[Tuple[str, str]] = ()
70+
metadata: Sequence[Tuple[str, Union[str, bytes]]] = ()
7171
):
7272
"""Instantiate the pager.
7373
@@ -81,8 +81,10 @@ def __init__(
8181
retry (google.api_core.retry.Retry): Designation of what errors,
8282
if any, should be retried.
8383
timeout (float): The timeout for this request.
84-
metadata (Sequence[Tuple[str, str]]): Strings which should be
85-
sent along with the request as metadata.
84+
metadata (Sequence[Tuple[str, Union[str, bytes]]]): Key/value pairs which should be
85+
sent along with the request as metadata. Normally, each value must be of type `str`,
86+
but for metadata keys ending with the suffix `-bin`, the corresponding values must
87+
be of type `bytes`.
8688
"""
8789
self._method = method
8890
self._request = managed_kafka.ListClustersRequest(request)
@@ -141,7 +143,7 @@ def __init__(
141143
*,
142144
retry: OptionalAsyncRetry = gapic_v1.method.DEFAULT,
143145
timeout: Union[float, object] = gapic_v1.method.DEFAULT,
144-
metadata: Sequence[Tuple[str, str]] = ()
146+
metadata: Sequence[Tuple[str, Union[str, bytes]]] = ()
145147
):
146148
"""Instantiates the pager.
147149
@@ -155,8 +157,10 @@ def __init__(
155157
retry (google.api_core.retry.AsyncRetry): Designation of what errors,
156158
if any, should be retried.
157159
timeout (float): The timeout for this request.
158-
metadata (Sequence[Tuple[str, str]]): Strings which should be
159-
sent along with the request as metadata.
160+
metadata (Sequence[Tuple[str, Union[str, bytes]]]): Key/value pairs which should be
161+
sent along with the request as metadata. Normally, each value must be of type `str`,
162+
but for metadata keys ending with the suffix `-bin`, the corresponding values must
163+
be of type `bytes`.
160164
"""
161165
self._method = method
162166
self._request = managed_kafka.ListClustersRequest(request)
@@ -219,7 +223,7 @@ def __init__(
219223
*,
220224
retry: OptionalRetry = gapic_v1.method.DEFAULT,
221225
timeout: Union[float, object] = gapic_v1.method.DEFAULT,
222-
metadata: Sequence[Tuple[str, str]] = ()
226+
metadata: Sequence[Tuple[str, Union[str, bytes]]] = ()
223227
):
224228
"""Instantiate the pager.
225229
@@ -233,8 +237,10 @@ def __init__(
233237
retry (google.api_core.retry.Retry): Designation of what errors,
234238
if any, should be retried.
235239
timeout (float): The timeout for this request.
236-
metadata (Sequence[Tuple[str, str]]): Strings which should be
237-
sent along with the request as metadata.
240+
metadata (Sequence[Tuple[str, Union[str, bytes]]]): Key/value pairs which should be
241+
sent along with the request as metadata. Normally, each value must be of type `str`,
242+
but for metadata keys ending with the suffix `-bin`, the corresponding values must
243+
be of type `bytes`.
238244
"""
239245
self._method = method
240246
self._request = managed_kafka.ListTopicsRequest(request)
@@ -293,7 +299,7 @@ def __init__(
293299
*,
294300
retry: OptionalAsyncRetry = gapic_v1.method.DEFAULT,
295301
timeout: Union[float, object] = gapic_v1.method.DEFAULT,
296-
metadata: Sequence[Tuple[str, str]] = ()
302+
metadata: Sequence[Tuple[str, Union[str, bytes]]] = ()
297303
):
298304
"""Instantiates the pager.
299305
@@ -307,8 +313,10 @@ def __init__(
307313
retry (google.api_core.retry.AsyncRetry): Designation of what errors,
308314
if any, should be retried.
309315
timeout (float): The timeout for this request.
310-
metadata (Sequence[Tuple[str, str]]): Strings which should be
311-
sent along with the request as metadata.
316+
metadata (Sequence[Tuple[str, Union[str, bytes]]]): Key/value pairs which should be
317+
sent along with the request as metadata. Normally, each value must be of type `str`,
318+
but for metadata keys ending with the suffix `-bin`, the corresponding values must
319+
be of type `bytes`.
312320
"""
313321
self._method = method
314322
self._request = managed_kafka.ListTopicsRequest(request)
@@ -371,7 +379,7 @@ def __init__(
371379
*,
372380
retry: OptionalRetry = gapic_v1.method.DEFAULT,
373381
timeout: Union[float, object] = gapic_v1.method.DEFAULT,
374-
metadata: Sequence[Tuple[str, str]] = ()
382+
metadata: Sequence[Tuple[str, Union[str, bytes]]] = ()
375383
):
376384
"""Instantiate the pager.
377385
@@ -385,8 +393,10 @@ def __init__(
385393
retry (google.api_core.retry.Retry): Designation of what errors,
386394
if any, should be retried.
387395
timeout (float): The timeout for this request.
388-
metadata (Sequence[Tuple[str, str]]): Strings which should be
389-
sent along with the request as metadata.
396+
metadata (Sequence[Tuple[str, Union[str, bytes]]]): Key/value pairs which should be
397+
sent along with the request as metadata. Normally, each value must be of type `str`,
398+
but for metadata keys ending with the suffix `-bin`, the corresponding values must
399+
be of type `bytes`.
390400
"""
391401
self._method = method
392402
self._request = managed_kafka.ListConsumerGroupsRequest(request)
@@ -445,7 +455,7 @@ def __init__(
445455
*,
446456
retry: OptionalAsyncRetry = gapic_v1.method.DEFAULT,
447457
timeout: Union[float, object] = gapic_v1.method.DEFAULT,
448-
metadata: Sequence[Tuple[str, str]] = ()
458+
metadata: Sequence[Tuple[str, Union[str, bytes]]] = ()
449459
):
450460
"""Instantiates the pager.
451461
@@ -459,8 +469,10 @@ def __init__(
459469
retry (google.api_core.retry.AsyncRetry): Designation of what errors,
460470
if any, should be retried.
461471
timeout (float): The timeout for this request.
462-
metadata (Sequence[Tuple[str, str]]): Strings which should be
463-
sent along with the request as metadata.
472+
metadata (Sequence[Tuple[str, Union[str, bytes]]]): Key/value pairs which should be
473+
sent along with the request as metadata. Normally, each value must be of type `str`,
474+
but for metadata keys ending with the suffix `-bin`, the corresponding values must
475+
be of type `bytes`.
464476
"""
465477
self._method = method
466478
self._request = managed_kafka.ListConsumerGroupsRequest(request)

0 commit comments

Comments
 (0)