Class: NewRelic::Agent::Instrumentation::ActiveRecordSubscriber
Instance Method Summary
collapse
#event_stack, #initialize, #log_notification_error, #pop_event, #push_event, subscribe, subscribed?
Instance Method Details
#active_record_config_for_event(event) ⇒ Object
84
85
86
87
88
89
90
91
92
|
# File 'lib/new_relic/agent/instrumentation/active_record_subscriber.rb', line 84
def active_record_config_for_event(event)
return unless event.payload[:connection_id] && NewRelic::LanguageSupport.object_space_enabled?
connection = ObjectSpace._id2ref(event.payload[:connection_id])
connection.instance_variable_get(:@config) if connection
end
|
#base_metric(event) ⇒ Object
#finish(name, id, payload) ⇒ Object
21
22
23
24
25
26
27
28
|
# File 'lib/new_relic/agent/instrumentation/active_record_subscriber.rb', line 21
def finish(name, id, payload)
return unless NewRelic::Agent.is_execution_traced?
event = pop_event(id)
record_metrics(event)
notice_sql(event)
rescue => e
log_notification_error(e, name, 'finish')
end
|
#get_explain_plan(config, query) ⇒ Object
30
31
32
33
34
35
36
37
38
|
# File 'lib/new_relic/agent/instrumentation/active_record_subscriber.rb', line 30
def get_explain_plan( config, query )
connection = NewRelic::Agent::Database.get_connection(config) do
::ActiveRecord::Base.send("#{config[:adapter]}_connection",
config)
end
if connection && connection.respond_to?(:execute)
return connection.execute("EXPLAIN #{query}")
end
end
|
#notice_sql(event) ⇒ Object
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
|
# File 'lib/new_relic/agent/instrumentation/active_record_subscriber.rb', line 40
def notice_sql(event)
config = active_record_config_for_event(event)
metric = base_metric(event)
scope = NewRelic::Agent.instance.stats_engine.push_scope(:active_record, event.time)
NewRelic::Agent.instance.transaction_sampler \
.notice_sql(event.payload[:sql], config,
Helper.milliseconds_to_seconds(event.duration),
&method(:get_explain_plan))
NewRelic::Agent.instance.sql_sampler \
.notice_sql(event.payload[:sql], metric, config,
Helper.milliseconds_to_seconds(event.duration),
&method(:get_explain_plan))
NewRelic::Agent.instance.stats_engine.pop_scope(scope, metric, event.end)
end
|
#record_metrics(event) ⇒ Object
#start(name, id, payload) ⇒ Object
14
15
16
17
18
19
|
# File 'lib/new_relic/agent/instrumentation/active_record_subscriber.rb', line 14
def start(name, id, payload)
return unless NewRelic::Agent.is_execution_traced?
super
rescue => e
log_notification_error(e, name, 'start')
end
|