lib/ddtrace/contrib/sidekiq/tracer.rb in ddtrace-0.10.0 vs lib/ddtrace/contrib/sidekiq/tracer.rb in ddtrace-0.11.0.beta1
- old
+ new
@@ -16,35 +16,17 @@
module Sidekiq
# Middleware is a Sidekiq server-side middleware which traces executed jobs
class Tracer
include Base
register_as :sidekiq
-
- option :enabled, default: true
- option :sidekiq_service, default: 'sidekiq'
+ option :service_name, default: 'sidekiq'
option :tracer, default: Datadog.tracer
- option :debug, default: false
- option :trace_agent_hostname, default: Writer::HOSTNAME
- option :trace_agent_port, default: Writer::PORT
def initialize(options = {})
- # check if Rails configuration is available and use it to override
- # Sidekiq defaults
- base_config = Datadog.configuration[:sidekiq].merge(Datadog.configuration[:rails])
- user_config = base_config.merge(options)
- @tracer = user_config[:tracer]
- @sidekiq_service = user_config[:sidekiq_service]
-
- # set Tracer status
- @tracer.enabled = user_config[:enabled]
- Datadog::Tracer.debug_logging = user_config[:debug]
-
- # configure the Tracer instance
- @tracer.configure(
- hostname: user_config[:trace_agent_hostname],
- port: user_config[:trace_agent_port]
- )
+ config = Datadog.configuration[:sidekiq].merge(options)
+ @tracer = config[:tracer]
+ @sidekiq_service = config[:service_name]
end
def call(worker, job, queue)
# If class is wrapping something else, the interesting resource info
# is the underlying, wrapped class, and not the wrapper.
@@ -84,10 +66,10 @@
{}
end
end
def sidekiq_service(resource)
- worker_config(resource).fetch(:service, @sidekiq_service)
+ worker_config(resource).fetch(:service_name, @sidekiq_service)
end
def set_service_info(service)
return if @tracer.services[service]
@tracer.set_service_info(