Class: TingYun::Agent::CrossAppMonitor

Inherits:
InboundRequestMonitor show all
Defined in:
lib/ting_yun/agent/cross_app/cross_app_monitor.rb

Constant Summary collapse

TY_ID_HEADER = 
'HTTP_X_TINGYUN'.freeze
TY_DATA_HEADER = 
'X-Tingyun-Data'.freeze

Instance Method Summary collapse

Methods inherited from InboundRequestMonitor

#initialize

Constructor Details

This class inherits a constructor from TingYun::Agent::InboundRequestMonitor

Instance Method Details

#build_payload(state) ⇒ Object 



68
69
70
71
72
73
74
75
76
77
78
79
80
 
# File 'lib/ting_yun/agent/cross_app/cross_app_monitor.rb', line 68

def build_payload(state)
  timings = state.timings

  payload = {
    :id => TingYun::Agent.config[:idSecret],
    :tname => state.transaction_name,
    :tid => state.current_transaction.guid,
    :rid => state.trace_id,
    :duration => timings.app_time_in_millis
  }

  payload
end

#insert_response_header(response_headers) ⇒ Object 



57
58
59
60
61
62
63
64
65
 
# File 'lib/ting_yun/agent/cross_app/cross_app_monitor.rb', line 57

def insert_response_header(response_headers)
  state = TingYun::Agent::TransactionState.tl_get
  txn = state.current_transaction
  if txn
    # set_response_headers
    response_headers[TY_DATA_HEADER] = TingYun::Support::Serialize::JSONWrapper.dump build_payload(state)
    TingYun::Agent.logger.debug("now,cross app will send response_headers  #{response_headers[TY_DATA_HEADER]}")
  end
end

#insert_response_headerV2(response_headers) ⇒ Object 



45
46
47
48
49
50
51
52
53
54
55
 
# File 'lib/ting_yun/agent/cross_app/cross_app_monitor.rb', line 45

def insert_response_headerV2(response_headers)
  state = TingYun::Agent::TransactionState.tl_get
  if state.same_account?
    txn = state.current_transaction
    if txn
      # set_response_headers
      response_headers[TY_DATA_HEADER] = TingYun::Support::Serialize::JSONWrapper.dump build_payload(state)
      TingYun::Agent.logger.debug("now,cross app will send response_headers  #{response_headers[TY_DATA_HEADER]}")
    end
  end
end

#on_finished_configuring(events) ⇒ Object 



18
19
20
 
# File 'lib/ting_yun/agent/cross_app/cross_app_monitor.rb', line 18

def on_finished_configuring(events)
  register_event_listeners(events)
end

#register_event_listeners(events) ⇒ Object

Expected sequence of events:

:before_call will save our cross application request id to the thread
:after_call will write our response headers/metrics and clean up the thread



26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
 
# File 'lib/ting_yun/agent/cross_app/cross_app_monitor.rb', line 26

def register_event_listeners(events)
  TingYun::Agent.logger.debug("Wiring up Cross Application Tracing to events after finished configuring")

  events.subscribe(:cross_app_before_call) do |env| #THREAD_LOCAL_ACCESS
    if TingYun::Agent::CrossAppTracing.cross_app_enabled?
      state = TingYun::Agent::TransactionState.tl_get
      if env[TY_ID_HEADER]
        state.save_referring_transaction_info(env[TY_ID_HEADER].split(';'))
      end
    end
  end

  events.subscribe(:cross_app_after_call) do |_status_code, headers, _body| #THREAD_LOCAL_ACCESS
    insert_response_header(headers) if TingYun::Agent::CrossAppTracing.cross_app_enabled?
  end

end