Sha256: 4c78ead1a711dbf0d1ef3402b3d28dd52980aae10118abfda53d7187ac464d11
Contents?: true
Size: 1.83 KB
Versions: 18
Compression:
Stored size: 1.83 KB
Contents
# encoding: utf-8
# This file is distributed under New Relic's license terms.
# See https://github.com/newrelic/newrelic-ruby-agent/blob/main/LICENSE for complete details.
require 'new_relic/agent/instrumentation/notifications_subscriber'
module NewRelic
module Agent
module Instrumentation
class ActiveStorageSubscriber < NotificationsSubscriber
def start name, id, payload
return unless state.is_execution_traced?
start_segment name, id, payload
rescue => e
log_notification_error e, name, 'start'
end
def finish name, id, payload
return unless state.is_execution_traced?
finish_segment id, payload
rescue => e
log_notification_error e, name, 'finish'
end
def start_segment name, id, payload
segment = Tracer.start_segment name: metric_name(name, payload)
segment.params[:key] = payload[:key]
segment.params[:exist] = payload[:exist] if payload.key? :exist
push_segment id, segment
end
def finish_segment id, payload
if segment = pop_segment(id)
if exception = exception_object(payload)
segment.notice_error(exception)
end
segment.finish
end
end
def metric_name name, payload
service = payload[:service]
method = method_from_name name
"Ruby/ActiveStorage/#{service}Service/#{method}"
end
PATTERN = /\Aservice_([^\.]*)\.active_storage\z/
UNKNOWN = "unknown".freeze
METHOD_NAME_MAPPING = Hash.new do |h, k|
if PATTERN =~ k
h[k] = $1
else
h[k] = UNKNOWN
end
end
def method_from_name name
METHOD_NAME_MAPPING[name]
end
end
end
end
end
Version data entries
18 entries across 18 versions & 1 rubygems