Sha256: 84c55679c86471120d82055052dbd651a95ae440e224d8161b2daefc18ca1fcc
Contents?: true
Size: 1.09 KB
Versions: 14
Compression:
Stored size: 1.09 KB
Contents
require 'ddtrace/ext/app_types'
require 'ddtrace/sync_writer'
require 'resque'
module Datadog
module Contrib
module Resque
# Uses Resque job hooks to create traces
module ResqueJob
def around_perform(*args)
pin = Pin.get_from(::Resque)
return yield unless pin && pin.tracer
pin.tracer.trace('resque.job', service: pin.service) do |span|
span.resource = name
span.span_type = pin.app_type
yield
span.service = pin.service
end
end
end
end
end
end
Resque.before_first_fork do
pin = Datadog::Pin.get_from(Resque)
next unless pin && pin.tracer
# Create SyncWriter instance before forking
sync_writer = Datadog::SyncWriter.new(transport: pin.tracer.writer.transport)
Datadog::Contrib::Resque.sync_writer = sync_writer
end
Resque.after_fork do
# get the current tracer
pin = Datadog::Pin.get_from(Resque)
next unless pin && pin.tracer
# clean the state so no CoW happens
pin.tracer.provider.context = nil
pin.tracer.writer = Datadog::Contrib::Resque.sync_writer
end
Version data entries
14 entries across 14 versions & 1 rubygems