Skip to content

Commit

Permalink
Fix rubocop
Browse files Browse the repository at this point in the history
  • Loading branch information
TonyCTHsu committed Nov 14, 2022
1 parent 04a5168 commit a39c4c1
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 2 deletions.
6 changes: 4 additions & 2 deletions lib/datadog/tracing/contrib/redis/instrumentation.rb
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,8 @@ module InstanceMethods
def call(*args, &block)
response = nil
Tracing.trace(Contrib::Redis::Ext::SPAN_COMMAND) do |span|
span.service = Datadog.configuration_for(redis_instance, :service_name) || datadog_configuration[:service_name]
span.service = Datadog.configuration_for(redis_instance, :service_name) ||
datadog_configuration[:service_name]
span.span_type = Contrib::Redis::Ext::TYPE
span.resource = get_command(args)
Contrib::Redis::Tags.set_common_tags(self, span)
Expand All @@ -35,7 +36,8 @@ def call(*args, &block)
def call_pipeline(*args, &block)
response = nil
Tracing.trace(Contrib::Redis::Ext::SPAN_COMMAND) do |span|
span.service = Datadog.configuration_for(redis_instance, :service_name) || datadog_configuration[:service_name]
span.service = Datadog.configuration_for(redis_instance, :service_name) ||
datadog_configuration[:service_name]
span.span_type = Contrib::Redis::Ext::TYPE
commands = get_pipeline_commands(args)
span.resource = commands.any? ? commands.join("\n") : '(none)'
Expand Down
4 changes: 4 additions & 0 deletions lib/datadog/tracing/contrib/redis/patcher.rb
Original file line number Diff line number Diff line change
Expand Up @@ -12,11 +12,13 @@ module Redis
module Patcher
include Contrib::Patcher

# Patch for redis instance
module InstancePatch
def self.included(base)
base.prepend(InstanceMethods)
end

# Instance method patch for redis instance
module InstanceMethods
def initialize(options = {})
options[:redis_instance] = self
Expand All @@ -26,11 +28,13 @@ def initialize(options = {})
end
end

# Patch for redis client
module ClientPatch
def self.included(base)
base.prepend(InstanceMethods)
end

# Instance method patch for redis client
module InstanceMethods
def initialize(options = {})
@redis_instance = options[:redis_instance]
Expand Down

0 comments on commit a39c4c1

Please sign in to comment.