Sha256: a77ca63b1e0e703fdd80ab19ea92e0007f55a37c245bfeead03613e992da73fc
Contents?: true
Size: 1.7 KB
Versions: 20
Compression:
Stored size: 1.7 KB
Contents
require 'skylight/formatters/http'
module Skylight
module Probes
module Excon
class Middleware < ::Excon::Middleware::Base
# This probably won't work since config isn't defined
include Util::Logging
def initialize(*)
@requests = {}
super
end
# TODO:
# - Consider whether a LIFO queue would be sufficient
# - Check that errors can't be called without a request
def request_call(datum)
begin_instrumentation(datum)
super
end
def response_call(datum)
super
ensure
end_instrumentation(datum)
end
def error_call(datum)
super
ensure
end_instrumentation(datum)
end
private
def begin_instrumentation(datum)
method = datum[:method].to_s
scheme = datum[:scheme]
host = datum[:host]
# TODO: Maybe don't show other default ports like 443
port = datum[:port] != 80 ? datum[:port] : nil
path = datum[:path]
query = datum[:query]
opts = Formatters::HTTP.build_opts(method, scheme, host, port, path, query)
@requests[datum.object_id] = Skylight.instrument(opts)
rescue Exception => e
error "failed to begin instrumentation for Excon; msg=%s", e.message
end
def end_instrumentation(datum)
if request = @requests.delete(datum.object_id)
Skylight.done(request)
end
rescue Exception => e
error "failed to end instrumentation for Excon; msg=%s", e.message
end
end
end
end
end
Version data entries
20 entries across 20 versions & 1 rubygems