1 files changed, 41 insertions, 0 deletions
diff --git a/lib/vendor/excon/lib/excon/middlewares/instrumentor.rb b/lib/vendor/excon/lib/excon/middlewares/instrumentor.rb
new file mode 100644
index 0000000..086016e
--- /dev/null
+++ b/lib/vendor/excon/lib/excon/middlewares/instrumentor.rb
@@ -0,0 +1,41 @@
+# frozen_string_literal: true
+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]) do
+            @stack.error_call(datum)
+          end
+        else
+          @stack.error_call(datum)
+        end
+      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]) do
+            @stack.response_call(datum)
+          end
+        else
+          @stack.response_call(datum)
+        end
+      end
+    end
+  end
+end