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
8 changes: 8 additions & 0 deletions api_names_out.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -296592,6 +296592,10 @@
"/managedkafka:v1/AddAclEntryResponse": add_acl_entry_response
"/managedkafka:v1/AddAclEntryResponse/acl": acl
"/managedkafka:v1/AddAclEntryResponse/aclCreated": acl_created
"/managedkafka:v1/BrokerDetails": broker_details
"/managedkafka:v1/BrokerDetails/brokerIndex": broker_index
"/managedkafka:v1/BrokerDetails/nodeId": node_id
"/managedkafka:v1/BrokerDetails/rack": rack
"/managedkafka:v1/CancelOperationRequest": cancel_operation_request
"/managedkafka:v1/CapacityConfig": capacity_config
"/managedkafka:v1/CapacityConfig/memoryBytes": memory_bytes
Expand All @@ -296609,9 +296613,12 @@
"/managedkafka:v1/CheckCompatibilityResponse/messages": messages
"/managedkafka:v1/CheckCompatibilityResponse/messages/message": message
"/managedkafka:v1/Cluster": cluster
"/managedkafka:v1/Cluster/brokerDetails": broker_details
"/managedkafka:v1/Cluster/brokerDetails/broker_detail": broker_detail
"/managedkafka:v1/Cluster/capacityConfig": capacity_config
"/managedkafka:v1/Cluster/createTime": create_time
"/managedkafka:v1/Cluster/gcpConfig": gcp_config
"/managedkafka:v1/Cluster/kafkaVersion": kafka_version
"/managedkafka:v1/Cluster/labels": labels
"/managedkafka:v1/Cluster/labels/label": label
"/managedkafka:v1/Cluster/name": name
Expand Down Expand Up @@ -296876,6 +296883,7 @@
"/managedkafka:v1/managedkafka.projects.locations.clusters.delete/requestId": request_id
"/managedkafka:v1/managedkafka.projects.locations.clusters.get": get_project_location_cluster
"/managedkafka:v1/managedkafka.projects.locations.clusters.get/name": name
"/managedkafka:v1/managedkafka.projects.locations.clusters.get/view": view
"/managedkafka:v1/managedkafka.projects.locations.clusters.list": list_project_location_clusters
"/managedkafka:v1/managedkafka.projects.locations.clusters.list/filter": filter
"/managedkafka:v1/managedkafka.projects.locations.clusters.list/orderBy": order_by
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.19.0 (2025-12-21)

* Regenerated from discovery document revision 20251212

### v0.18.0 (2025-12-14)

* Regenerated from discovery document revision 20251204
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -186,6 +186,37 @@ def update!(**args)
end
end

# Details of a broker in the Kafka cluster.
class BrokerDetails
include Google::Apis::Core::Hashable

# Output only. The index of the broker.
# Corresponds to the JSON property `brokerIndex`
# @return [Fixnum]
attr_accessor :broker_index

# Output only. The node id of the broker.
# Corresponds to the JSON property `nodeId`
# @return [Fixnum]
attr_accessor :node_id

# Output only. The rack of the broker.
# Corresponds to the JSON property `rack`
# @return [String]
attr_accessor :rack

def initialize(**args)
update!(**args)
end

# Update properties of this object
def update!(**args)
@broker_index = args[:broker_index] if args.key?(:broker_index)
@node_id = args[:node_id] if args.key?(:node_id)
@rack = args[:rack] if args.key?(:rack)
end
end

# The request message for Operations.CancelOperation.
class CancelOperationRequest
include Google::Apis::Core::Hashable
Expand Down Expand Up @@ -316,6 +347,12 @@ def update!(**args)
class Cluster
include Google::Apis::Core::Hashable

# Output only. Only populated when FULL view is requested. Details of each
# broker in the cluster.
# Corresponds to the JSON property `brokerDetails`
# @return [Array<Google::Apis::ManagedkafkaV1::BrokerDetails>]
attr_accessor :broker_details

# A capacity configuration of a Kafka cluster.
# Corresponds to the JSON property `capacityConfig`
# @return [Google::Apis::ManagedkafkaV1::CapacityConfig]
Expand All @@ -331,6 +368,12 @@ class Cluster
# @return [Google::Apis::ManagedkafkaV1::GcpConfig]
attr_accessor :gcp_config

# Output only. Only populated when FULL view is requested. The Kafka version of
# the cluster.
# Corresponds to the JSON property `kafkaVersion`
# @return [String]
attr_accessor :kafka_version

# Optional. Labels as key value pairs.
# Corresponds to the JSON property `labels`
# @return [Hash<String,String>]
Expand Down Expand Up @@ -387,9 +430,11 @@ def initialize(**args)

# Update properties of this object
def update!(**args)
@broker_details = args[:broker_details] if args.key?(:broker_details)
@capacity_config = args[:capacity_config] if args.key?(:capacity_config)
@create_time = args[:create_time] if args.key?(:create_time)
@gcp_config = args[:gcp_config] if args.key?(:gcp_config)
@kafka_version = args[:kafka_version] if args.key?(:kafka_version)
@labels = args[:labels] if args.key?(:labels)
@name = args[:name] if args.key?(:name)
@rebalance_config = args[:rebalance_config] if args.key?(:rebalance_config)
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.18.0"
GEM_VERSION = "0.19.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 = "20251204"
REVISION = "20251212"
end
end
end
Original file line number Diff line number Diff line change
Expand Up @@ -46,6 +46,12 @@ class Representation < Google::Apis::Core::JsonRepresentation; end
include Google::Apis::Core::JsonObjectSupport
end

class BrokerDetails
class Representation < Google::Apis::Core::JsonRepresentation; end

include Google::Apis::Core::JsonObjectSupport
end

class CancelOperationRequest
class Representation < Google::Apis::Core::JsonRepresentation; end

Expand Down Expand Up @@ -440,6 +446,15 @@ class Representation < Google::Apis::Core::JsonRepresentation
end
end

class BrokerDetails
# @private
class Representation < Google::Apis::Core::JsonRepresentation
property :broker_index, :numeric_string => true, as: 'brokerIndex'
property :node_id, :numeric_string => true, as: 'nodeId'
property :rack, as: 'rack'
end
end

class CancelOperationRequest
# @private
class Representation < Google::Apis::Core::JsonRepresentation
Expand Down Expand Up @@ -483,11 +498,14 @@ class Representation < Google::Apis::Core::JsonRepresentation
class Cluster
# @private
class Representation < Google::Apis::Core::JsonRepresentation
collection :broker_details, as: 'brokerDetails', class: Google::Apis::ManagedkafkaV1::BrokerDetails, decorator: Google::Apis::ManagedkafkaV1::BrokerDetails::Representation

property :capacity_config, as: 'capacityConfig', class: Google::Apis::ManagedkafkaV1::CapacityConfig, decorator: Google::Apis::ManagedkafkaV1::CapacityConfig::Representation

property :create_time, as: 'createTime'
property :gcp_config, as: 'gcpConfig', class: Google::Apis::ManagedkafkaV1::GcpConfig, decorator: Google::Apis::ManagedkafkaV1::GcpConfig::Representation

property :kafka_version, as: 'kafkaVersion'
hash :labels, as: 'labels'
property :name, as: 'name'
property :rebalance_config, as: 'rebalanceConfig', class: Google::Apis::ManagedkafkaV1::RebalanceConfig, decorator: Google::Apis::ManagedkafkaV1::RebalanceConfig::Representation
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -225,6 +225,9 @@ def delete_project_location_cluster(name, request_id: nil, fields: nil, quota_us
# Returns the properties of a single cluster.
# @param [String] name
# Required. The name of the cluster whose configuration to return.
# @param [String] view
# Optional. Specifies the view of the Cluster resource to be returned. Defaults
# to CLUSTER_VIEW_BASIC. See the ClusterView enum for possible values.
# @param [String] fields
# Selector specifying which fields to include in a partial response.
# @param [String] quota_user
Expand All @@ -242,11 +245,12 @@ def delete_project_location_cluster(name, request_id: nil, fields: nil, quota_us
# @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 get_project_location_cluster(name, fields: nil, quota_user: nil, options: nil, &block)
def get_project_location_cluster(name, view: nil, fields: nil, quota_user: nil, options: nil, &block)
command = make_simple_command(:get, 'v1/{+name}', options)
command.response_representation = Google::Apis::ManagedkafkaV1::Cluster::Representation
command.response_class = Google::Apis::ManagedkafkaV1::Cluster
command.params['name'] = name unless name.nil?
command.query['view'] = view unless view.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