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 



30
31
32
33
34
35
36
37
38
39
 
# File 'lib/instana/instrumentation/excon.rb', line 30

def error_call(datum)
  return @stack.error_call(datum) unless ::Instana.tracer.tracing?

  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 



5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
 
# File 'lib/instana/instrumentation/excon.rb', line 5

def request_call(datum)
  return @stack.request_call(datum) unless ::Instana.tracer.tracing?

  payload = { :http => {} }
  path = datum[:path].split('?').first
  payload[:http][:url] = "#{datum[:connection].instance_variable_get(:@socket_key)}#{path}"
  payload[:http][:method] = datum[:method] if datum.key?(:method)

  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.log_async_entry(:excon, payload)
    t_context = datum[:instana_span].context
  else
    ::Instana.tracer.log_entry(:excon, payload)
    t_context = ::Instana.tracer.context
  end

  # Set request headers; encode IDs as hexadecimal strings
  datum[:headers]['X-Instana-T'] = t_context.trace_id_header
  datum[:headers]['X-Instana-S'] = t_context.span_id_header

  @stack.request_call(datum)
end

#response_call(datum) ⇒ Object 



41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
 
# File 'lib/instana/instrumentation/excon.rb', line 41

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

  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.between?(500, 511)
    # 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