Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 4 additions & 0 deletions api_names_out.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -288499,6 +288499,8 @@
"/managedkafka:v1/ListOperationsResponse/nextPageToken": next_page_token
"/managedkafka:v1/ListOperationsResponse/operations": operations
"/managedkafka:v1/ListOperationsResponse/operations/operation": operation
"/managedkafka:v1/ListOperationsResponse/unreachable": unreachable
"/managedkafka:v1/ListOperationsResponse/unreachable/unreachable": unreachable
"/managedkafka:v1/ListSchemaRegistriesResponse": list_schema_registries_response
"/managedkafka:v1/ListSchemaRegistriesResponse/schemaRegistries": schema_registries
"/managedkafka:v1/ListSchemaRegistriesResponse/schemaRegistries/schema_registry": schema_registry
Expand Down Expand Up @@ -288588,6 +288590,7 @@
"/managedkafka:v1/TaskRetryPolicy": task_retry_policy
"/managedkafka:v1/TaskRetryPolicy/maximumBackoff": maximum_backoff
"/managedkafka:v1/TaskRetryPolicy/minimumBackoff": minimum_backoff
"/managedkafka:v1/TaskRetryPolicy/taskRetryDisabled": task_retry_disabled
"/managedkafka:v1/TlsConfig": tls_config
"/managedkafka:v1/TlsConfig/sslPrincipalMappingRules": ssl_principal_mapping_rules
"/managedkafka:v1/TlsConfig/trustConfig": trust_config
Expand Down Expand Up @@ -288731,6 +288734,7 @@
"/managedkafka:v1/managedkafka.projects.locations.operations.list/name": name
"/managedkafka:v1/managedkafka.projects.locations.operations.list/pageSize": page_size
"/managedkafka:v1/managedkafka.projects.locations.operations.list/pageToken": page_token
"/managedkafka:v1/managedkafka.projects.locations.operations.list/returnPartialSuccess": return_partial_success
"/managedkafka:v1/managedkafka.projects.locations.schemaRegistries.compatibility.checkCompatibility": check_project_location_schema_registry_compatibility_compatibility
"/managedkafka:v1/managedkafka.projects.locations.schemaRegistries.compatibility.checkCompatibility/name": name
"/managedkafka:v1/managedkafka.projects.locations.schemaRegistries.config.delete": delete_project_location_schema_registry_config
Expand Down
4 changes: 4 additions & 0 deletions generated/google-apis-managedkafka_v1/CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,5 +1,9 @@
# Release history for google-apis-managedkafka_v1

### v0.15.0 (2025-10-26)

* Regenerated from discovery document revision 20251016

### v0.14.0 (2025-09-21)

* Regenerated from discovery document revision 20250911
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -480,7 +480,7 @@ class ConnectCluster
attr_accessor :satisfies_pzs
alias_method :satisfies_pzs?, :satisfies_pzs

# Output only. The current state of the cluster.
# Output only. The current state of the Kafka Connect cluster.
# Corresponds to the JSON property `state`
# @return [String]
attr_accessor :state
Expand Down Expand Up @@ -603,13 +603,15 @@ class Connector
# @return [String]
attr_accessor :state

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

# Unordered list. Unreachable resources. Populated when the request sets `
# ListOperationsRequest.return_partial_success` and reads across collections e.g.
# when attempting to list all resources across all supported locations.
# Corresponds to the JSON property `unreachable`
# @return [Array<String>]
attr_accessor :unreachable

def initialize(**args)
update!(**args)
end
Expand All @@ -1119,6 +1128,7 @@ def initialize(**args)
def update!(**args)
@next_page_token = args[:next_page_token] if args.key?(:next_page_token)
@operations = args[:operations] if args.key?(:operations)
@unreachable = args[:unreachable] if args.key?(:unreachable)
end
end

Expand Down Expand Up @@ -1804,13 +1814,15 @@ def update!(**args)
end
end

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

Expand All @@ -1826,6 +1838,12 @@ class TaskRetryPolicy
# @return [String]
attr_accessor :minimum_backoff

# Optional. If true, task retry is disabled.
# Corresponds to the JSON property `taskRetryDisabled`
# @return [Boolean]
attr_accessor :task_retry_disabled
alias_method :task_retry_disabled?, :task_retry_disabled

def initialize(**args)
update!(**args)
end
Expand All @@ -1834,6 +1852,7 @@ def initialize(**args)
def update!(**args)
@maximum_backoff = args[:maximum_backoff] if args.key?(:maximum_backoff)
@minimum_backoff = args[:minimum_backoff] if args.key?(:minimum_backoff)
@task_retry_disabled = args[:task_retry_disabled] if args.key?(:task_retry_disabled)
end
end

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,13 +16,13 @@ module Google
module Apis
module ManagedkafkaV1
# Version of the google-apis-managedkafka_v1 gem
GEM_VERSION = "0.14.0"
GEM_VERSION = "0.15.0"

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

# Revision of the discovery document this client was generated from
REVISION = "20250911"
REVISION = "20251016"
end
end
end
Original file line number Diff line number Diff line change
Expand Up @@ -707,6 +707,7 @@ class Representation < Google::Apis::Core::JsonRepresentation
property :next_page_token, as: 'nextPageToken'
collection :operations, as: 'operations', class: Google::Apis::ManagedkafkaV1::Operation, decorator: Google::Apis::ManagedkafkaV1::Operation::Representation

collection :unreachable, as: 'unreachable'
end
end

Expand Down Expand Up @@ -916,6 +917,7 @@ class TaskRetryPolicy
class Representation < Google::Apis::Core::JsonRepresentation
property :maximum_backoff, as: 'maximumBackoff'
property :minimum_backoff, as: 'minimumBackoff'
property :task_retry_disabled, as: 'taskRetryDisabled'
end
end

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1629,6 +1629,13 @@ def get_project_location_operation(name, fields: nil, quota_user: nil, options:
# The standard list page size.
# @param [String] page_token
# The standard list page token.
# @param [Boolean] return_partial_success
# When set to `true`, operations that are reachable are returned as normal, and
# those that are unreachable are returned in the [ListOperationsResponse.
# unreachable] field. This can only be `true` when reading across collections e.
# g. when `parent` is set to `"projects/example/locations/-"`. This field is not
# by default supported and will result in an `UNIMPLEMENTED` error if set unless
# explicitly documented otherwise in service or product specific documentation.
# @param [String] fields
# Selector specifying which fields to include in a partial response.
# @param [String] quota_user
Expand All @@ -1646,14 +1653,15 @@ def get_project_location_operation(name, fields: nil, quota_user: nil, options:
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
# @raise [Google::Apis::AuthorizationError] Authorization is required
def list_project_location_operations(name, filter: nil, page_size: nil, page_token: nil, fields: nil, quota_user: nil, options: nil, &block)
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)
command = make_simple_command(:get, 'v1/{+name}/operations', options)
command.response_representation = Google::Apis::ManagedkafkaV1::ListOperationsResponse::Representation
command.response_class = Google::Apis::ManagedkafkaV1::ListOperationsResponse
command.params['name'] = name unless name.nil?
command.query['filter'] = filter unless filter.nil?
command.query['pageSize'] = page_size unless page_size.nil?
command.query['pageToken'] = page_token unless page_token.nil?
command.query['returnPartialSuccess'] = return_partial_success unless return_partial_success.nil?
command.query['fields'] = fields unless fields.nil?
command.query['quotaUser'] = quota_user unless quota_user.nil?
execute_or_queue_command(command, &block)
Expand Down