Sha256: ff880cf5436c088034e24cf72ac137ba86cf1cf0025d2a5f7e85a8203fa7f96c
Contents?: true
Size: 1.15 KB
Versions: 18
Compression:
Stored size: 1.15 KB
Contents
# frozen_string_literal: true
module Datadog
module Tracing
module Contrib
module DelayedJob
module ServerInternalTracer
# Trace when DelayedJob looks for a new job to work on
module Worker
def reserve_job
configuration = Datadog.configuration.tracing[:delayed_job]
Datadog::Tracing.trace(Ext::SPAN_RESERVE_JOB, service: configuration[:service_name]) do |span|
span.type = Datadog::Tracing::Metadata::Ext::AppTypes::TYPE_WORKER
span.set_tag(Contrib::Ext::Messaging::TAG_SYSTEM, Ext::TAG_COMPONENT)
span.set_tag(Datadog::Tracing::Metadata::Ext::TAG_COMPONENT, Ext::TAG_COMPONENT)
span.set_tag(Datadog::Tracing::Metadata::Ext::TAG_OPERATION, Ext::TAG_OPERATION_RESERVE_JOB)
# Set analytics sample rate
if Contrib::Analytics.enabled?(configuration[:analytics_enabled])
Contrib::Analytics.set_sample_rate(span, configuration[:analytics_sample_rate])
end
super
end
end
end
end
end
end
end
end
Version data entries
18 entries across 18 versions & 1 rubygems