class Datadog::Contrib::Sneakers::Tracer
Tracer
is a Sneakers
server-side middleware which traces executed jobs
Public Class Methods
new(app, *args)
click to toggle source
# File lib/ddtrace/contrib/sneakers/tracer.rb, line 10 def initialize(app, *args) @app = app @args = args end
Public Instance Methods
call(deserialized_msg, delivery_info, metadata, handler)
click to toggle source
# File lib/ddtrace/contrib/sneakers/tracer.rb, line 15 def call(deserialized_msg, delivery_info, metadata, handler) trace_options = { service: configuration[:service_name], span_type: Datadog::Ext::AppTypes::WORKER } request_span = tracer.trace(Ext::SPAN_JOB, trace_options) # Set analytics sample rate if Datadog::Contrib::Analytics.enabled?(configuration[:analytics_enabled]) Datadog::Contrib::Analytics.set_sample_rate(request_span, configuration[:analytics_sample_rate]) end # Measure service stats Contrib::Analytics.set_measured(request_span) request_span.resource = @app.to_proc.binding.eval('self.class').to_s request_span.set_tag(Ext::TAG_JOB_ROUTING_KEY, delivery_info.routing_key) request_span.set_tag(Ext::TAG_JOB_QUEUE, delivery_info.consumer.queue.name) if configuration[:tag_body] request_span.set_tag(Ext::TAG_JOB_BODY, deserialized_msg) end @app.call(deserialized_msg, delivery_info, metadata, handler) rescue StandardError => e request_span.set_error(e) unless request_span.nil? raise e ensure request_span.finish if request_span end
Private Instance Methods
configuration()
click to toggle source
# File lib/ddtrace/contrib/sneakers/tracer.rb, line 52 def configuration Datadog.configuration[:sneakers] end
tracer()
click to toggle source
# File lib/ddtrace/contrib/sneakers/tracer.rb, line 48 def tracer configuration[:tracer] end