class OpenTelemetry::Instrumentation::Excon::Middlewares::TracerMiddleware
Excon
middleware for instrumentation
Constants
- HTTP_METHODS_SYMBOL_TO_STRING
Public Class Methods
around_default_stack()
click to toggle source
Returns a copy of the default stack with the trace middleware injected
# File lib/opentelemetry/instrumentation/excon/middlewares/tracer_middleware.rb, line 60 def self.around_default_stack ::Excon.defaults[:middlewares].dup.tap do |default_stack| # If the default stack contains a version of the trace middleware already... existing_trace_middleware = default_stack.find { |m| m <= TracerMiddleware } default_stack.delete(existing_trace_middleware) if existing_trace_middleware # Inject after the ResponseParser middleware response_middleware_index = default_stack.index(::Excon::Middleware::ResponseParser).to_i default_stack.insert(response_middleware_index + 1, self) end end
Public Instance Methods
error_call(datum)
click to toggle source
# File lib/opentelemetry/instrumentation/excon/middlewares/tracer_middleware.rb, line 54 def error_call(datum) handle_response(datum) @stack.error_call(datum) end
request_call(datum)
click to toggle source
# File lib/opentelemetry/instrumentation/excon/middlewares/tracer_middleware.rb, line 25 def request_call(datum) begin unless datum.key?(:otel_span) http_method = HTTP_METHODS_SYMBOL_TO_STRING[datum[:method]] attributes = span_creation_attributes(datum, http_method) tracer.start_span( "HTTP #{http_method}", attributes: attributes, kind: :client ).tap do |span| datum[:otel_span] = span OpenTelemetry::Trace.with_span(span) do OpenTelemetry.propagation.inject(datum[:headers]) end end end rescue StandardError => e OpenTelemetry.logger.debug(e.message) end @stack.request_call(datum) end
response_call(datum)
click to toggle source
# File lib/opentelemetry/instrumentation/excon/middlewares/tracer_middleware.rb, line 48 def response_call(datum) @stack.response_call(datum).tap do |d| handle_response(d) end end
Private Instance Methods
handle_response(datum)
click to toggle source
# File lib/opentelemetry/instrumentation/excon/middlewares/tracer_middleware.rb, line 74 def handle_response(datum) # rubocop:disable Metrics/AbcSize, Metrics/CyclomaticComplexity: if datum.key?(:otel_span) datum[:otel_span].tap do |span| return span if span.end_timestamp if datum.key?(:response) response = datum[:response] span.set_attribute('http.status_code', response[:status]) span.status = OpenTelemetry::Trace::Status.error unless (100..399).include?(response[:status].to_i) end span.status = OpenTelemetry::Trace::Status.error("Request has failed: #{datum[:error]}") if datum.key?(:error) span.finish datum.delete(:otel_span) end end rescue StandardError => e OpenTelemetry.logger.debug(e.message) end
span_creation_attributes(datum, http_method)
click to toggle source
# File lib/opentelemetry/instrumentation/excon/middlewares/tracer_middleware.rb, line 95 def span_creation_attributes(datum, http_method) instrumentation_attrs = { 'http.host' => datum[:host], 'http.method' => http_method, 'http.scheme' => datum[:scheme], 'http.target' => datum[:path] } config = Excon::Instrumentation.instance.config instrumentation_attrs['peer.service'] = config[:peer_service] if config[:peer_service] instrumentation_attrs.merge( OpenTelemetry::Common::HTTP::ClientContext.attributes ) end
tracer()
click to toggle source
# File lib/opentelemetry/instrumentation/excon/middlewares/tracer_middleware.rb, line 109 def tracer Excon::Instrumentation.instance.tracer end