Skip to content

Commit ffbc137

Browse files
feat: Automated regeneration of managedkafka v1 client
1 parent d872bb6 commit ffbc137

File tree

6 files changed

+55
-18
lines changed

6 files changed

+55
-18
lines changed

api_names_out.yaml

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -288499,6 +288499,8 @@
288499288499
"/managedkafka:v1/ListOperationsResponse/nextPageToken": next_page_token
288500288500
"/managedkafka:v1/ListOperationsResponse/operations": operations
288501288501
"/managedkafka:v1/ListOperationsResponse/operations/operation": operation
288502+
"/managedkafka:v1/ListOperationsResponse/unreachable": unreachable
288503+
"/managedkafka:v1/ListOperationsResponse/unreachable/unreachable": unreachable
288502288504
"/managedkafka:v1/ListSchemaRegistriesResponse": list_schema_registries_response
288503288505
"/managedkafka:v1/ListSchemaRegistriesResponse/schemaRegistries": schema_registries
288504288506
"/managedkafka:v1/ListSchemaRegistriesResponse/schemaRegistries/schema_registry": schema_registry
@@ -288588,6 +288590,7 @@
288588288590
"/managedkafka:v1/TaskRetryPolicy": task_retry_policy
288589288591
"/managedkafka:v1/TaskRetryPolicy/maximumBackoff": maximum_backoff
288590288592
"/managedkafka:v1/TaskRetryPolicy/minimumBackoff": minimum_backoff
288593+
"/managedkafka:v1/TaskRetryPolicy/taskRetryDisabled": task_retry_disabled
288591288594
"/managedkafka:v1/TlsConfig": tls_config
288592288595
"/managedkafka:v1/TlsConfig/sslPrincipalMappingRules": ssl_principal_mapping_rules
288593288596
"/managedkafka:v1/TlsConfig/trustConfig": trust_config
@@ -288731,6 +288734,7 @@
288731288734
"/managedkafka:v1/managedkafka.projects.locations.operations.list/name": name
288732288735
"/managedkafka:v1/managedkafka.projects.locations.operations.list/pageSize": page_size
288733288736
"/managedkafka:v1/managedkafka.projects.locations.operations.list/pageToken": page_token
288737+
"/managedkafka:v1/managedkafka.projects.locations.operations.list/returnPartialSuccess": return_partial_success
288734288738
"/managedkafka:v1/managedkafka.projects.locations.schemaRegistries.compatibility.checkCompatibility": check_project_location_schema_registry_compatibility_compatibility
288735288739
"/managedkafka:v1/managedkafka.projects.locations.schemaRegistries.compatibility.checkCompatibility/name": name
288736288740
"/managedkafka:v1/managedkafka.projects.locations.schemaRegistries.config.delete": delete_project_location_schema_registry_config

generated/google-apis-managedkafka_v1/CHANGELOG.md

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,9 @@
11
# Release history for google-apis-managedkafka_v1
22

3+
### v0.15.0 (2025-10-26)
4+
5+
* Regenerated from discovery document revision 20251016
6+
37
### v0.14.0 (2025-09-21)
48

59
* Regenerated from discovery document revision 20250911

generated/google-apis-managedkafka_v1/lib/google/apis/managedkafka_v1/classes.rb

Lines changed: 34 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -480,7 +480,7 @@ class ConnectCluster
480480
attr_accessor :satisfies_pzs
481481
alias_method :satisfies_pzs?, :satisfies_pzs
482482

483-
# Output only. The current state of the cluster.
483+
# Output only. The current state of the Kafka Connect cluster.
484484
# Corresponds to the JSON property `state`
485485
# @return [String]
486486
attr_accessor :state
@@ -603,13 +603,15 @@ class Connector
603603
# @return [String]
604604
attr_accessor :state
605605

606-
# Task Retry Policy is implemented on a best-effort basis. Retry delay will be
607-
# exponential based on provided minimum and maximum backoffs. https://en.
608-
# wikipedia.org/wiki/Exponential_backoff. Note that the delay between
609-
# consecutive task restarts may not always precisely match the configured
610-
# settings. This can happen when the ConnectCluster is in rebalancing state or
611-
# if the ConnectCluster is unresponsive etc. The default values for minimum and
612-
# maximum backoffs are 60 seconds and 30 minutes respectively.
606+
# Task Retry Policy is implemented on a best-effort basis. The default policy
607+
# retries tasks with a minimum_backoff of 60 seconds, and a maximum_backoff of
608+
# 12 hours. You can disable the policy by setting the task_retry_disabled field
609+
# to true. Retry delay will be exponential based on provided minimum and maximum
610+
# backoffs. https://en.wikipedia.org/wiki/Exponential_backoff. Note that the
611+
# delay between consecutive task restarts may not always precisely match the
612+
# configured settings. This can happen when the ConnectCluster is in rebalancing
613+
# state or if the ConnectCluster is unresponsive etc. The default values for
614+
# minimum and maximum backoffs are 60 seconds and 12 hours respectively.
613615
# Corresponds to the JSON property `taskRestartPolicy`
614616
# @return [Google::Apis::ManagedkafkaV1::TaskRetryPolicy]
615617
attr_accessor :task_restart_policy
@@ -1111,6 +1113,13 @@ class ListOperationsResponse
11111113
# @return [Array<Google::Apis::ManagedkafkaV1::Operation>]
11121114
attr_accessor :operations
11131115

1116+
# Unordered list. Unreachable resources. Populated when the request sets `
1117+
# ListOperationsRequest.return_partial_success` and reads across collections e.g.
1118+
# when attempting to list all resources across all supported locations.
1119+
# Corresponds to the JSON property `unreachable`
1120+
# @return [Array<String>]
1121+
attr_accessor :unreachable
1122+
11141123
def initialize(**args)
11151124
update!(**args)
11161125
end
@@ -1119,6 +1128,7 @@ def initialize(**args)
11191128
def update!(**args)
11201129
@next_page_token = args[:next_page_token] if args.key?(:next_page_token)
11211130
@operations = args[:operations] if args.key?(:operations)
1131+
@unreachable = args[:unreachable] if args.key?(:unreachable)
11221132
end
11231133
end
11241134

@@ -1804,13 +1814,15 @@ def update!(**args)
18041814
end
18051815
end
18061816

1807-
# Task Retry Policy is implemented on a best-effort basis. Retry delay will be
1808-
# exponential based on provided minimum and maximum backoffs. https://en.
1809-
# wikipedia.org/wiki/Exponential_backoff. Note that the delay between
1810-
# consecutive task restarts may not always precisely match the configured
1811-
# settings. This can happen when the ConnectCluster is in rebalancing state or
1812-
# if the ConnectCluster is unresponsive etc. The default values for minimum and
1813-
# maximum backoffs are 60 seconds and 30 minutes respectively.
1817+
# Task Retry Policy is implemented on a best-effort basis. The default policy
1818+
# retries tasks with a minimum_backoff of 60 seconds, and a maximum_backoff of
1819+
# 12 hours. You can disable the policy by setting the task_retry_disabled field
1820+
# to true. Retry delay will be exponential based on provided minimum and maximum
1821+
# backoffs. https://en.wikipedia.org/wiki/Exponential_backoff. Note that the
1822+
# delay between consecutive task restarts may not always precisely match the
1823+
# configured settings. This can happen when the ConnectCluster is in rebalancing
1824+
# state or if the ConnectCluster is unresponsive etc. The default values for
1825+
# minimum and maximum backoffs are 60 seconds and 12 hours respectively.
18141826
class TaskRetryPolicy
18151827
include Google::Apis::Core::Hashable
18161828

@@ -1826,6 +1838,12 @@ class TaskRetryPolicy
18261838
# @return [String]
18271839
attr_accessor :minimum_backoff
18281840

1841+
# Optional. If true, task retry is disabled.
1842+
# Corresponds to the JSON property `taskRetryDisabled`
1843+
# @return [Boolean]
1844+
attr_accessor :task_retry_disabled
1845+
alias_method :task_retry_disabled?, :task_retry_disabled
1846+
18291847
def initialize(**args)
18301848
update!(**args)
18311849
end
@@ -1834,6 +1852,7 @@ def initialize(**args)
18341852
def update!(**args)
18351853
@maximum_backoff = args[:maximum_backoff] if args.key?(:maximum_backoff)
18361854
@minimum_backoff = args[:minimum_backoff] if args.key?(:minimum_backoff)
1855+
@task_retry_disabled = args[:task_retry_disabled] if args.key?(:task_retry_disabled)
18371856
end
18381857
end
18391858

generated/google-apis-managedkafka_v1/lib/google/apis/managedkafka_v1/gem_version.rb

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -16,13 +16,13 @@ module Google
1616
module Apis
1717
module ManagedkafkaV1
1818
# Version of the google-apis-managedkafka_v1 gem
19-
GEM_VERSION = "0.14.0"
19+
GEM_VERSION = "0.15.0"
2020

2121
# Version of the code generator used to generate this client
2222
GENERATOR_VERSION = "0.18.0"
2323

2424
# Revision of the discovery document this client was generated from
25-
REVISION = "20250911"
25+
REVISION = "20251016"
2626
end
2727
end
2828
end

generated/google-apis-managedkafka_v1/lib/google/apis/managedkafka_v1/representations.rb

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -707,6 +707,7 @@ class Representation < Google::Apis::Core::JsonRepresentation
707707
property :next_page_token, as: 'nextPageToken'
708708
collection :operations, as: 'operations', class: Google::Apis::ManagedkafkaV1::Operation, decorator: Google::Apis::ManagedkafkaV1::Operation::Representation
709709

710+
collection :unreachable, as: 'unreachable'
710711
end
711712
end
712713

@@ -916,6 +917,7 @@ class TaskRetryPolicy
916917
class Representation < Google::Apis::Core::JsonRepresentation
917918
property :maximum_backoff, as: 'maximumBackoff'
918919
property :minimum_backoff, as: 'minimumBackoff'
920+
property :task_retry_disabled, as: 'taskRetryDisabled'
919921
end
920922
end
921923

generated/google-apis-managedkafka_v1/lib/google/apis/managedkafka_v1/service.rb

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1629,6 +1629,13 @@ def get_project_location_operation(name, fields: nil, quota_user: nil, options:
16291629
# The standard list page size.
16301630
# @param [String] page_token
16311631
# The standard list page token.
1632+
# @param [Boolean] return_partial_success
1633+
# When set to `true`, operations that are reachable are returned as normal, and
1634+
# those that are unreachable are returned in the [ListOperationsResponse.
1635+
# unreachable] field. This can only be `true` when reading across collections e.
1636+
# g. when `parent` is set to `"projects/example/locations/-"`. This field is not
1637+
# by default supported and will result in an `UNIMPLEMENTED` error if set unless
1638+
# explicitly documented otherwise in service or product specific documentation.
16321639
# @param [String] fields
16331640
# Selector specifying which fields to include in a partial response.
16341641
# @param [String] quota_user
@@ -1646,14 +1653,15 @@ def get_project_location_operation(name, fields: nil, quota_user: nil, options:
16461653
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
16471654
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
16481655
# @raise [Google::Apis::AuthorizationError] Authorization is required
1649-
def list_project_location_operations(name, filter: nil, page_size: nil, page_token: nil, fields: nil, quota_user: nil, options: nil, &block)
1656+
def list_project_location_operations(name, filter: nil, page_size: nil, page_token: nil, return_partial_success: nil, fields: nil, quota_user: nil, options: nil, &block)
16501657
command = make_simple_command(:get, 'v1/{+name}/operations', options)
16511658
command.response_representation = Google::Apis::ManagedkafkaV1::ListOperationsResponse::Representation
16521659
command.response_class = Google::Apis::ManagedkafkaV1::ListOperationsResponse
16531660
command.params['name'] = name unless name.nil?
16541661
command.query['filter'] = filter unless filter.nil?
16551662
command.query['pageSize'] = page_size unless page_size.nil?
16561663
command.query['pageToken'] = page_token unless page_token.nil?
1664+
command.query['returnPartialSuccess'] = return_partial_success unless return_partial_success.nil?
16571665
command.query['fields'] = fields unless fields.nil?
16581666
command.query['quotaUser'] = quota_user unless quota_user.nil?
16591667
execute_or_queue_command(command, &block)

0 commit comments

Comments
 (0)