Sha256: ee18520d1d03e351bce9d6c1534bb626b474cbbf3df509687dc58e9206b6ff89
Contents?: true
Size: 807 Bytes
Versions: 17
Compression:
Stored size: 807 Bytes
Contents
# This file is distributed under New Relic's license terms.
# See https://github.com/newrelic/newrelic-ruby-agent/blob/main/LICENSE for complete details.
# frozen_string_literal: true
module NewRelic::Agent::Instrumentation::Sidekiq
class Client
include Sidekiq::ClientMiddleware if defined?(Sidekiq::ClientMiddleware)
INSTRUMENTATION_NAME = 'SidekiqClient'
def call(_worker_class, job, *_)
NewRelic::Agent.record_instrumentation_invocation(INSTRUMENTATION_NAME)
job[NewRelic::NEWRELIC_KEY] ||= distributed_tracing_headers if ::NewRelic::Agent.config[:'distributed_tracing.enabled']
yield
end
def distributed_tracing_headers
headers = {}
::NewRelic::Agent::DistributedTracing.insert_distributed_trace_headers(headers)
headers
end
end
end
Version data entries
17 entries across 17 versions & 1 rubygems