Class: Datadog::Contrib::Que::Tracer

Inherits:
Object
  • Object
show all
Defined in:
lib/ddtrace/contrib/que/tracer.rb

Overview

Tracer is a Que's server-side middleware which traces executed jobs

Instance Method Summary collapse

Instance Method Details

#call(job) ⇒ Object 



11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
 
# File 'lib/ddtrace/contrib/que/tracer.rb', line 11

def call(job)
  trace_options = {
    service: configuration[:service_name],
    span_type: Datadog::Ext::AppTypes::WORKER,
    on_error: configuration[:error_handler]
  }

  tracer.trace(Ext::SPAN_JOB, trace_options) do |request_span|
    request_span.resource = job.class.name.to_s
    request_span.set_tag(Ext::TAG_JOB_QUEUE, job.que_attrs[:queue])
    request_span.set_tag(Ext::TAG_JOB_ID, job.que_attrs[:id])
    request_span.set_tag(Ext::TAG_JOB_PRIORITY, job.que_attrs[:priority])
    request_span.set_tag(Ext::TAG_JOB_ERROR_COUNT, job.que_attrs[:error_count])
    request_span.set_tag(Ext::TAG_JOB_RUN_AT, job.que_attrs[:run_at])
    request_span.set_tag(Ext::TAG_JOB_EXPIRED_AT, job.que_attrs[:expired_at])
    request_span.set_tag(Ext::TAG_JOB_FINISHED_AT, job.que_attrs[:finished_at])
    request_span.set_tag(Ext::TAG_JOB_ARGS, job.que_attrs[:args]) if configuration[:tag_args]
    request_span.set_tag(Ext::TAG_JOB_DATA, job.que_attrs[:data]) if configuration[:tag_data]

    set_sample_rate(request_span)
    Contrib::Analytics.set_measured(request_span)

    yield
  end
end