Sha256: d65ffd7c349a8e6e2cbd3029647ab52a7de62bfdfbec06599eccdf50ce29c55e
Contents?: true
Size: 1.74 KB
Versions: 7
Compression:
Stored size: 1.74 KB
Contents
module RailsPerformance
module Instrument
class MetricsCollector
# payload
# {
# controller: "PostsController",
# action: "index",
# params: {"action" => "index", "controller" => "posts"},
# headers: #<ActionDispatch::Http::Headers:0x0055a67a519b88>,
# format: :html,
# method: "GET",
# path: "/posts",
# status: 200,
# view_runtime: 46.848,
# db_runtime: 0.157
# }
def call(event_name, started, finished, event_id, payload)
return if RailsPerformance.skip
return if CurrentRequest.current.data
# TODO do we need this new?
event = ActiveSupport::Notifications::Event.new(event_name, started, finished, event_id, payload)
return if RailsPerformance.ignored_endpoints.include? "#{event.payload[:controller]}##{event.payload[:action]}"
return if RailsPerformance.ignored_paths.any? { |p| event.payload[:path].start_with?(p) }
record = {
controller: event.payload[:controller],
action: event.payload[:action],
format: event.payload[:format],
status: event.payload[:status],
datetime: finished.strftime(RailsPerformance::FORMAT),
datetimei: finished.to_i,
method: event.payload[:method],
path: event.payload[:path],
view_runtime: event.payload[:view_runtime],
db_runtime: event.payload[:db_runtime],
duration: event.duration,
exception: event.payload[:exception],
exception_object: event.payload[:exception_object]
}
# pass the record to Thread.current
# and saves later in middleware
CurrentRequest.current.data = record
end
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems