Sha256: 33a3d4f5e12ab10015d44470f448fce9b6a7cfa4e098fb951ba1d0d563d02da6
Contents?: true
Size: 1.01 KB
Versions: 72
Compression:
Stored size: 1.01 KB
Contents
module Excon
module Middleware
class Instrumentor < Excon::Middleware::Base
def error_call(datum)
if datum.has_key?(:instrumentor)
datum[:instrumentor].instrument("#{datum[:instrumentor_name]}.error", :error => datum[:error])
end
@stack.error_call(datum)
end
def request_call(datum)
if datum.has_key?(:instrumentor)
if datum[:retries_remaining] < datum[:retry_limit]
event_name = "#{datum[:instrumentor_name]}.retry"
else
event_name = "#{datum[:instrumentor_name]}.request"
end
datum[:instrumentor].instrument(event_name, datum) do
@stack.request_call(datum)
end
else
@stack.request_call(datum)
end
end
def response_call(datum)
if datum.has_key?(:instrumentor)
datum[:instrumentor].instrument("#{datum[:instrumentor_name]}.response", datum[:response])
end
@stack.response_call(datum)
end
end
end
end
Version data entries
72 entries across 72 versions & 5 rubygems