Skip to content

feat: [Memorystore for Redis Cluster] Add support for Flexible CA feature #33455

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
gcf-owl-bot wants to merge 2 commits into
base: main
Choose a base branch
from
Open

feat: [Memorystore for Redis Cluster] Add support for Flexible CA feature #33455

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
34f65d7
feat: [Memorystore for Redis Cluster] Add support for Flexible CA fea…
gcf-owl-bot[bot] Mar 30, 2026
34bb8a3
🦉 Updates from OwlBot post-processor
gcf-owl-bot[bot] Mar 30, 2026
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
1 change: 1 addition & 0 deletions google-cloud-redis-cluster-v1beta1/.owlbot-manifest.json
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -55,6 +55,7 @@
"snippets/cloud_redis_cluster/get_backup_collection.rb",
"snippets/cloud_redis_cluster/get_cluster.rb",
"snippets/cloud_redis_cluster/get_cluster_certificate_authority.rb",
"snippets/cloud_redis_cluster/get_shared_regional_certificate_authority.rb",
"snippets/cloud_redis_cluster/list_backup_collections.rb",
"snippets/cloud_redis_cluster/list_backups.rb",
"snippets/cloud_redis_cluster/list_clusters.rb",
Expand Down
5 changes: 5 additions & 0 deletions google-cloud-redis-cluster-v1beta1/gapic_metadata.json
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -40,6 +40,11 @@
"get_cluster_certificate_authority"
]
},
"GetSharedRegionalCertificateAuthority": {
"methods": [
"get_shared_regional_certificate_authority"
]
},
"RescheduleClusterMaintenance": {
"methods": [
"reschedule_cluster_maintenance"
Expand Down
95 changes: 95 additions & 0 deletions ...edis-cluster-v1beta1/lib/google/cloud/redis/cluster/v1beta1/cloud_redis_cluster/client.rb
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -865,6 +865,94 @@ def get_cluster_certificate_authority request, options = nil
raise ::Google::Cloud::Error.from_error(e)
end

##
# Gets the details of regional certificate authority information for Redis
# cluster.
#
# @overload get_shared_regional_certificate_authority(request, options = nil)
# Pass arguments to `get_shared_regional_certificate_authority` via a request object, either of type
# {::Google::Cloud::Redis::Cluster::V1beta1::GetSharedRegionalCertificateAuthorityRequest} or an equivalent Hash.
#
# @param request [::Google::Cloud::Redis::Cluster::V1beta1::GetSharedRegionalCertificateAuthorityRequest, ::Hash]
# A request object representing the call parameters. Required. To specify no
# parameters, or to keep all the default parameter values, pass an empty Hash.
# @param options [::Gapic::CallOptions, ::Hash]
# Overrides the default settings for this call, e.g, timeout, retries, etc. Optional.
#
# @overload get_shared_regional_certificate_authority(name: nil)
# Pass arguments to `get_shared_regional_certificate_authority` via keyword arguments. Note that at
# least one keyword argument is required. To specify no parameters, or to keep all
# the default parameter values, pass an empty Hash as a request object (see above).
#
# @param name [::String]
# Required. Regional certificate authority resource name using the form:
# `projects/{project_id}/locations/{location_id}/sharedRegionalCertificateAuthority`
# where `location_id` refers to a Google Cloud region.
#
# @yield [response, operation] Access the result along with the RPC operation
# @yieldparam response [::Google::Cloud::Redis::Cluster::V1beta1::SharedRegionalCertificateAuthority]
# @yieldparam operation [::GRPC::ActiveCall::Operation]
#
# @return [::Google::Cloud::Redis::Cluster::V1beta1::SharedRegionalCertificateAuthority]
#
# @raise [::Google::Cloud::Error] if the RPC is aborted.
#
# @example Basic example
# require "google/cloud/redis/cluster/v1beta1"
#
# # Create a client object. The client can be reused for multiple calls.
# client = Google::Cloud::Redis::Cluster::V1beta1::CloudRedisCluster::Client.new
#
# # Create a request. To set request fields, pass in keyword arguments.
# request = Google::Cloud::Redis::Cluster::V1beta1::GetSharedRegionalCertificateAuthorityRequest.new
#
# # Call the get_shared_regional_certificate_authority method.
# result = client.get_shared_regional_certificate_authority request
#
# # The returned object is of type Google::Cloud::Redis::Cluster::V1beta1::SharedRegionalCertificateAuthority.
# p result
#
def get_shared_regional_certificate_authority request, options = nil
raise ::ArgumentError, "request must be provided" if request.nil?

request = ::Gapic::Protobuf.coerce request, to: ::Google::Cloud::Redis::Cluster::V1beta1::GetSharedRegionalCertificateAuthorityRequest

# Converts hash and nil to an options object
options = ::Gapic::CallOptions.new(**options.to_h) if options.respond_to? :to_h

# Customize the options with defaults
metadata = @config.rpcs.get_shared_regional_certificate_authority.metadata.to_h

# Set x-goog-api-client, x-goog-user-project and x-goog-api-version headers
metadata[:"x-goog-api-client"] ||= ::Gapic::Headers.x_goog_api_client \
lib_name: @config.lib_name, lib_version: @config.lib_version,
gapic_version: ::Google::Cloud::Redis::Cluster::V1beta1::VERSION
metadata[:"x-goog-api-version"] = API_VERSION unless API_VERSION.empty?
metadata[:"x-goog-user-project"] = @quota_project_id if @quota_project_id

header_params = {}
if request.name
header_params["name"] = request.name
end

request_params_header = header_params.map { |k, v| "#{k}=#{v}" }.join("&")
metadata[:"x-goog-request-params"] ||= request_params_header

options.apply_defaults timeout: @config.rpcs.get_shared_regional_certificate_authority.timeout,
metadata: metadata,
retry_policy: @config.rpcs.get_shared_regional_certificate_authority.retry_policy

options.apply_defaults timeout: @config.timeout,
metadata: @config.metadata,
retry_policy: @config.retry_policy

@cloud_redis_cluster_stub.call_rpc :get_shared_regional_certificate_authority, request, options: options do |response, operation|
yield response, operation if block_given?
end
rescue ::GRPC::BadStatus => e
raise ::Google::Cloud::Error.from_error(e)
end

##
# Reschedules upcoming maintenance event.
#
Expand Down Expand Up @@ -1874,6 +1962,11 @@ class Rpcs
#
attr_reader :get_cluster_certificate_authority
##
# RPC-specific configuration for `get_shared_regional_certificate_authority`
# @return [::Gapic::Config::Method]
#
attr_reader :get_shared_regional_certificate_authority
##
# RPC-specific configuration for `reschedule_cluster_maintenance`
# @return [::Gapic::Config::Method]
#
Expand Down Expand Up @@ -1928,6 +2021,8 @@ def initialize parent_rpcs = nil
@create_cluster = ::Gapic::Config::Method.new create_cluster_config
get_cluster_certificate_authority_config = parent_rpcs.get_cluster_certificate_authority if parent_rpcs.respond_to? :get_cluster_certificate_authority
@get_cluster_certificate_authority = ::Gapic::Config::Method.new get_cluster_certificate_authority_config
get_shared_regional_certificate_authority_config = parent_rpcs.get_shared_regional_certificate_authority if parent_rpcs.respond_to? :get_shared_regional_certificate_authority
@get_shared_regional_certificate_authority = ::Gapic::Config::Method.new get_shared_regional_certificate_authority_config
reschedule_cluster_maintenance_config = parent_rpcs.reschedule_cluster_maintenance if parent_rpcs.respond_to? :reschedule_cluster_maintenance
@reschedule_cluster_maintenance = ::Gapic::Config::Method.new reschedule_cluster_maintenance_config
list_backup_collections_config = parent_rpcs.list_backup_collections if parent_rpcs.respond_to? :list_backup_collections
Expand Down
36 changes: 36 additions & 0 deletions ...redis-cluster-v1beta1/lib/google/cloud/redis/cluster/v1beta1/cloud_redis_cluster/paths.rb
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -65,6 +65,25 @@ def backup_collection_path project:, location:, backup_collection:
"projects/#{project}/locations/#{location}/backupCollections/#{backup_collection}"
end

##
# Create a fully-qualified CaPool resource string.
#
# The resource will be in the following format:
#
# `projects/{project}/locations/{location}/caPools/{ca_pool}`
#
# @param project [String]
# @param location [String]
# @param ca_pool [String]
#
# @return [::String]
def ca_pool_path project:, location:, ca_pool:
raise ::ArgumentError, "project cannot contain /" if project.to_s.include? "/"
raise ::ArgumentError, "location cannot contain /" if location.to_s.include? "/"

"projects/#{project}/locations/#{location}/caPools/#{ca_pool}"
end

##
# Create a fully-qualified CertificateAuthority resource string.
#
Expand Down Expand Up @@ -219,6 +238,23 @@ def service_attachment_path project:, region:, service_attachment:
"projects/#{project}/regions/#{region}/serviceAttachments/#{service_attachment}"
end

##
# Create a fully-qualified SharedRegionalCertificateAuthority resource string.
#
# The resource will be in the following format:
#
# `projects/{project}/locations/{location}/sharedRegionalCertificateAuthority`
#
# @param project [String]
# @param location [String]
#
# @return [::String]
def shared_regional_certificate_authority_path project:, location:
raise ::ArgumentError, "project cannot contain /" if project.to_s.include? "/"

"projects/#{project}/locations/#{location}/sharedRegionalCertificateAuthority"
end

extend self
end
end
Expand Down
88 changes: 88 additions & 0 deletions ...cluster-v1beta1/lib/google/cloud/redis/cluster/v1beta1/cloud_redis_cluster/rest/client.rb
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -817,6 +817,87 @@ def get_cluster_certificate_authority request, options = nil
raise ::Google::Cloud::Error.from_error(e)
end

##
# Gets the details of regional certificate authority information for Redis
# cluster.
#
# @overload get_shared_regional_certificate_authority(request, options = nil)
# Pass arguments to `get_shared_regional_certificate_authority` via a request object, either of type
# {::Google::Cloud::Redis::Cluster::V1beta1::GetSharedRegionalCertificateAuthorityRequest} or an equivalent Hash.
#
# @param request [::Google::Cloud::Redis::Cluster::V1beta1::GetSharedRegionalCertificateAuthorityRequest, ::Hash]
# A request object representing the call parameters. Required. To specify no
# parameters, or to keep all the default parameter values, pass an empty Hash.
# @param options [::Gapic::CallOptions, ::Hash]
# Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
#
# @overload get_shared_regional_certificate_authority(name: nil)
# Pass arguments to `get_shared_regional_certificate_authority` via keyword arguments. Note that at
# least one keyword argument is required. To specify no parameters, or to keep all
# the default parameter values, pass an empty Hash as a request object (see above).
#
# @param name [::String]
# Required. Regional certificate authority resource name using the form:
# `projects/{project_id}/locations/{location_id}/sharedRegionalCertificateAuthority`
# where `location_id` refers to a Google Cloud region.
# @yield [result, operation] Access the result along with the TransportOperation object
# @yieldparam result [::Google::Cloud::Redis::Cluster::V1beta1::SharedRegionalCertificateAuthority]
# @yieldparam operation [::Gapic::Rest::TransportOperation]
#
# @return [::Google::Cloud::Redis::Cluster::V1beta1::SharedRegionalCertificateAuthority]
#
# @raise [::Google::Cloud::Error] if the REST call is aborted.
#
# @example Basic example
# require "google/cloud/redis/cluster/v1beta1"
#
# # Create a client object. The client can be reused for multiple calls.
# client = Google::Cloud::Redis::Cluster::V1beta1::CloudRedisCluster::Rest::Client.new
#
# # Create a request. To set request fields, pass in keyword arguments.
# request = Google::Cloud::Redis::Cluster::V1beta1::GetSharedRegionalCertificateAuthorityRequest.new
#
# # Call the get_shared_regional_certificate_authority method.
# result = client.get_shared_regional_certificate_authority request
#
# # The returned object is of type Google::Cloud::Redis::Cluster::V1beta1::SharedRegionalCertificateAuthority.
# p result
#
def get_shared_regional_certificate_authority request, options = nil
raise ::ArgumentError, "request must be provided" if request.nil?

request = ::Gapic::Protobuf.coerce request, to: ::Google::Cloud::Redis::Cluster::V1beta1::GetSharedRegionalCertificateAuthorityRequest

# Converts hash and nil to an options object
options = ::Gapic::CallOptions.new(**options.to_h) if options.respond_to? :to_h

# Customize the options with defaults
call_metadata = @config.rpcs.get_shared_regional_certificate_authority.metadata.to_h

# Set x-goog-api-client, x-goog-user-project and x-goog-api-version headers
call_metadata[:"x-goog-api-client"] ||= ::Gapic::Headers.x_goog_api_client \
lib_name: @config.lib_name, lib_version: @config.lib_version,
gapic_version: ::Google::Cloud::Redis::Cluster::V1beta1::VERSION,
transports_version_send: [:rest]

call_metadata[:"x-goog-api-version"] = API_VERSION unless API_VERSION.empty?
call_metadata[:"x-goog-user-project"] = @quota_project_id if @quota_project_id

options.apply_defaults timeout: @config.rpcs.get_shared_regional_certificate_authority.timeout,
metadata: call_metadata,
retry_policy: @config.rpcs.get_shared_regional_certificate_authority.retry_policy

options.apply_defaults timeout: @config.timeout,
metadata: @config.metadata,
retry_policy: @config.retry_policy

@cloud_redis_cluster_stub.get_shared_regional_certificate_authority request, options do |result, operation|
yield result, operation if block_given?
end
rescue ::Gapic::Rest::Error => e
raise ::Google::Cloud::Error.from_error(e)
end

##
# Reschedules upcoming maintenance event.
#
Expand Down Expand Up @@ -1740,6 +1821,11 @@ class Rpcs
#
attr_reader :get_cluster_certificate_authority
##
# RPC-specific configuration for `get_shared_regional_certificate_authority`
# @return [::Gapic::Config::Method]
#
attr_reader :get_shared_regional_certificate_authority
##
# RPC-specific configuration for `reschedule_cluster_maintenance`
# @return [::Gapic::Config::Method]
#
Expand Down Expand Up @@ -1794,6 +1880,8 @@ def initialize parent_rpcs = nil
@create_cluster = ::Gapic::Config::Method.new create_cluster_config
get_cluster_certificate_authority_config = parent_rpcs.get_cluster_certificate_authority if parent_rpcs.respond_to? :get_cluster_certificate_authority
@get_cluster_certificate_authority = ::Gapic::Config::Method.new get_cluster_certificate_authority_config
get_shared_regional_certificate_authority_config = parent_rpcs.get_shared_regional_certificate_authority if parent_rpcs.respond_to? :get_shared_regional_certificate_authority
@get_shared_regional_certificate_authority = ::Gapic::Config::Method.new get_shared_regional_certificate_authority_config
reschedule_cluster_maintenance_config = parent_rpcs.reschedule_cluster_maintenance if parent_rpcs.respond_to? :reschedule_cluster_maintenance
@reschedule_cluster_maintenance = ::Gapic::Config::Method.new reschedule_cluster_maintenance_config
list_backup_collections_config = parent_rpcs.list_backup_collections if parent_rpcs.respond_to? :list_backup_collections
Expand Down
Loading
Loading