class Datadog::Contrib::Que::Tracer

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

Public Instance Methods

call(job) { || ... } click to toggle source
# File lib/ddtrace/contrib/que/tracer.rb, line 10
def call(job)
  trace_options = {
    service:   configuration[:service_name],
    span_type: Datadog::Ext::AppTypes::WORKER
  }

  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

Private Instance Methods

configuration() click to toggle source
# File lib/ddtrace/contrib/que/tracer.rb, line 50
def configuration
  Datadog.configuration[Datadog::Contrib::Que::Ext::APP.to_sym]
end
set_sample_rate(request_span) click to toggle source
# File lib/ddtrace/contrib/que/tracer.rb, line 37
def set_sample_rate(request_span)
  if Contrib::Analytics.enabled?(configuration[:analytics_enabled])
    Contrib::Analytics.set_sample_rate(
      request_span,
      configuration[:analytics_sample_rate]
    )
  end
end
tracer() click to toggle source
# File lib/ddtrace/contrib/que/tracer.rb, line 46
def tracer
  configuration[:tracer]
end