Class: Instana::Instrumentation::Excon

Inherits:
Excon::Middleware::Base
  • Object
show all
Defined in:
lib/instana/instrumentation/excon.rb

Instance Method Summary collapse

Instance Method Details

#error_call(datum) ⇒ Object 



40
41
42
43
44
45
46
47
48
49
 
# File 'lib/instana/instrumentation/excon.rb', line 40

def error_call(datum)
  return @stack.error_call(datum) unless traceable?

  if datum[:pipeline] == true
    ::Instana.tracer.log_async_error(datum[:error], datum[:instana_span])
  else
    ::Instana.tracer.log_error(datum[:error])
  end
  @stack.error_call(datum)
end

#request_call(datum) ⇒ Object 



7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
 
# File 'lib/instana/instrumentation/excon.rb', line 7

def request_call(datum)
  return @stack.request_call(datum) unless traceable?

  payload = { :http => {} }
  path, query = datum[:path].split('?', 2)
  payload[:http][:url] = ::Instana.secrets.remove_from_query("#{datum[:connection].instance_variable_get(:@socket_key)}#{path}")
  payload[:http][:method] = datum[:method] if datum.key?(:method)
  payload[:http][:params] = ::Instana.secrets.remove_from_query(query || '')

  if datum[:pipeline] == true
    # Pass the context along in the datum so we get back on response
    # and can close out the async span
    datum[:instana_span] = ::Instana.tracer.start_span(:excon, attributes: payload)
    t_context = datum[:instana_span].context
  else
    ::Instana.tracer.start_span(:excon, attributes: payload)
    t_context = ::Instana.tracer.context
  end

  # Set request headers; encode IDs as hexadecimal strings
  datum[:headers]['X-Instana-L'] = t_context.level.to_s

  if t_context.active?
    datum[:headers]['X-Instana-T'] = t_context.trace_id_header
    datum[:headers]['X-Instana-S'] = t_context.span_id_header
  end

  datum[:headers]['Traceparent'] = t_context.trace_parent_header
  datum[:headers]['Tracestate'] = t_context.trace_state_header unless t_context.trace_state_header.empty?

  @stack.request_call(datum)
end

#response_call(datum) ⇒ Object 



51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
 
# File 'lib/instana/instrumentation/excon.rb', line 51

def response_call(datum)
  # FIXME: Will connect exceptions call a response?
  #
  return @stack.response_call(datum) unless traceable?

  result =  @stack.response_call(datum)

  status = datum[:status]
  if !status && datum.key?(:response) && datum[:response].is_a?(Hash)
    status = datum[:response][:status]
  end

  if status >= 500
    # Because of the 5xx response, we flag this span as errored but
    # without a backtrace (no exception)
    ::Instana.tracer.log_error(nil)
  end

  if datum[:pipeline] == true
    # Pickup context of this async span from datum[:instana_span]
    ::Instana.tracer.log_async_exit(:excon, { :http => {:status => status } }, datum[:instana_span])
  else
    ::Instana.tracer.log_exit(:excon, { :http => {:status => status } })
  end
  result
end