Sha256: 8f334f4d43b2db940b54c271bd51dd69e85cc29038b9c2068f567ba37fc18a34
Contents?: true
Size: 1.51 KB
Versions: 27
Compression:
Stored size: 1.51 KB
Contents
# Inserts a new middleware between each actual middleware in the application,
# so as to trace the time for each one.
#
# Currently disabled by default due to the overhead of this approach (~10-15ms
# per request in practice). Instead, middleware as a whole are instrumented
# via the MiddlewareSummary class.
#
# Turn this on with the configuration setting `detailed_middleware` set to true
module ScoutApm
module Instruments
class MiddlewareDetailed
def initalize(logger=ScoutApm::Agent.instance.logger)
@logger = logger
@installed = false
end
def installed?
@installed
end
def install
@installed = true
if defined?(ActionDispatch) && defined?(ActionDispatch::MiddlewareStack) && defined?(ActionDispatch::MiddlewareStack::Middleware)
ActionDispatch::MiddlewareStack::Middleware.class_eval do
def build(app)
ScoutApm::Agent.instance.logger.info("Building Middleware #{klass.name}")
new_mw = klass.new(app, *args, &block)
MiddlewareWrapper.new(new_mw, klass.name)
end
end
end
end
class MiddlewareWrapper
def initialize(app, name)
@app = app
@type = "Middleware"
@name = name
end
def call(env)
req = ScoutApm::RequestManager.lookup
req.start_layer( ScoutApm::Layer.new(@type, @name) )
@app.call(env)
ensure
req.stop_layer
end
end
end
end
end
Version data entries
27 entries across 27 versions & 1 rubygems