client.rb in google-cloud-redis-cluster-v1beta1-0.2.0

- old
+ new

@@ -189,19 +189,31 @@
 
                   @cloud_redis_cluster_stub = ::Google::Cloud::Redis::Cluster::V1beta1::CloudRedisCluster::Rest::ServiceStub.new(
                     endpoint: @config.endpoint,
                     endpoint_template: DEFAULT_ENDPOINT_TEMPLATE,
                     universe_domain: @config.universe_domain,
-                    credentials: credentials
+                    credentials: credentials,
+                    logger: @config.logger
                   )
 
+                  @cloud_redis_cluster_stub.logger(stub: true)&.info do |entry|
+                    entry.set_system_name
+                    entry.set_service
+                    entry.message = "Created client for #{entry.service}"
+                    entry.set_credentials_fields credentials
+                    entry.set "customEndpoint", @config.endpoint if @config.endpoint
+                    entry.set "defaultTimeout", @config.timeout if @config.timeout
+                    entry.set "quotaProject", @quota_project_id if @quota_project_id
+                  end
+
                   @location_client = Google::Cloud::Location::Locations::Rest::Client.new do |config|
                     config.credentials = credentials
                     config.quota_project = @quota_project_id
                     config.endpoint = @cloud_redis_cluster_stub.endpoint
                     config.universe_domain = @cloud_redis_cluster_stub.universe_domain
                     config.bindings_override = @config.bindings_override
+                    config.logger = @cloud_redis_cluster_stub.logger if config.respond_to? :logger=
                   end
                 end
 
                 ##
                 # Get the associated client for long-running operations.
@@ -215,10 +227,19 @@
                 #
                 # @return [Google::Cloud::Location::Locations::Rest::Client]
                 #
                 attr_reader :location_client
 
+                ##
+                # The logger used for request/response debug logging.
+                #
+                # @return [Logger]
+                #
+                def logger
+                  @cloud_redis_cluster_stub.logger
+                end
+
                 # Service calls
 
                 ##
                 # Lists all Redis clusters owned by a project in either the specified
                 # location (region) or all locations.
@@ -315,11 +336,10 @@
                                          metadata:     @config.metadata,
                                          retry_policy: @config.retry_policy
 
                   @cloud_redis_cluster_stub.list_clusters request, options do |result, operation|
                     yield result, operation if block_given?
-                    return result
                   end
                 rescue ::Gapic::Rest::Error => e
                   raise ::Google::Cloud::Error.from_error(e)
                 end
 
@@ -396,11 +416,10 @@
                                          metadata:     @config.metadata,
                                          retry_policy: @config.retry_policy
 
                   @cloud_redis_cluster_stub.get_cluster request, options do |result, operation|
                     yield result, operation if block_given?
-                    return result
                   end
                 rescue ::Gapic::Rest::Error => e
                   raise ::Google::Cloud::Error.from_error(e)
                 end
 
@@ -497,11 +516,11 @@
                                          retry_policy: @config.retry_policy
 
                   @cloud_redis_cluster_stub.update_cluster request, options do |result, operation|
                     result = ::Gapic::Operation.new result, @operations_client, options: options
                     yield result, operation if block_given?
-                    return result
+                    throw :response, result
                   end
                 rescue ::Gapic::Rest::Error => e
                   raise ::Google::Cloud::Error.from_error(e)
                 end
 
@@ -589,11 +608,11 @@
                                          retry_policy: @config.retry_policy
 
                   @cloud_redis_cluster_stub.delete_cluster request, options do |result, operation|
                     result = ::Gapic::Operation.new result, @operations_client, options: options
                     yield result, operation if block_given?
-                    return result
+                    throw :response, result
                   end
                 rescue ::Gapic::Rest::Error => e
                   raise ::Google::Cloud::Error.from_error(e)
                 end
 
@@ -698,11 +717,11 @@
                                          retry_policy: @config.retry_policy
 
                   @cloud_redis_cluster_stub.create_cluster request, options do |result, operation|
                     result = ::Gapic::Operation.new result, @operations_client, options: options
                     yield result, operation if block_given?
-                    return result
+                    throw :response, result
                   end
                 rescue ::Gapic::Rest::Error => e
                   raise ::Google::Cloud::Error.from_error(e)
                 end
 
@@ -779,11 +798,10 @@
                                          metadata:     @config.metadata,
                                          retry_policy: @config.retry_policy
 
                   @cloud_redis_cluster_stub.get_cluster_certificate_authority request, options do |result, operation|
                     yield result, operation if block_given?
-                    return result
                   end
                 rescue ::Gapic::Rest::Error => e
                   raise ::Google::Cloud::Error.from_error(e)
                 end
 
@@ -859,10 +877,15 @@
                 # @!attribute [rw] universe_domain
                 #   The universe domain within which to make requests. This determines the
                 #   default endpoint URL. The default value of nil uses the environment
                 #   universe (usually the default "googleapis.com" universe).
                 #   @return [::String,nil]
+                # @!attribute [rw] logger
+                #   A custom logger to use for request/response debug logging, or the value
+                #   `:default` (the default) to construct a default logger, or `nil` to
+                #   explicitly disable logging.
+                #   @return [::Logger,:default,nil]
                 #
                 class Configuration
                   extend ::Gapic::Config
 
                   # @private
@@ -887,9 +910,10 @@
                   # Overrides for http bindings for the RPCs of this service
                   # are only used when this service is used as mixin, and only
                   # by the host service.
                   # @return [::Hash{::Symbol=>::Array<::Gapic::Rest::GrpcTranscoder::HttpBinding>}]
                   config_attr :bindings_override, {}, ::Hash, nil
+                  config_attr :logger, :default, ::Logger, nil, :default
 
                   # @private
                   def initialize parent_config = nil
                     @parent_config = parent_config unless parent_config.nil?
 