Sha256: b8cb1028e0628572465b0f98a0aa13b39bd18ecb04b72fbc884ebbb0a3c24ebb
Contents?: true
Size: 1.1 KB
Versions: 26
Compression:
Stored size: 1.1 KB
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
require 'new_relic/agent/instrumentation/notifications_subscriber'
module NewRelic
module Agent
module Instrumentation
class ActiveJobSubscriber < NotificationsSubscriber
PAYLOAD_KEYS = %i[adapter db_runtime error job wait]
def add_segment_params(segment, payload)
PAYLOAD_KEYS.each do |key|
segment.params[key] = payload[key] if payload.key?(key)
end
end
def metric_name(name, payload)
queue = payload[:job].queue_name
method = method_from_name(name)
"Ruby/ActiveJob/#{queue}/#{method}"
end
PATTERN = /\A([^\.]+)\.active_job\z/
METHOD_NAME_MAPPING = Hash.new do |h, k|
if PATTERN =~ k
h[k] = $1
else
h[k] = NewRelic::UNKNOWN
end
end
def method_from_name(name)
METHOD_NAME_MAPPING[name]
end
end
end
end
end
Version data entries
26 entries across 26 versions & 1 rubygems