Class: NewRelic::TransactionSample
Defined Under Namespace
Classes: CompositeSegment, IDGenerator, Segment, SummarySegment
Constant Summary
collapse
- EMPTY_ARRAY =
[].freeze
- @@start_time =
Time.now
Instance Attribute Summary collapse
Class Method Summary
collapse
Instance Method Summary
collapse
#breakdown_data, #database_time, #render_time, #sql_segments
Constructor Details
#initialize(time = Time.now.to_f, sample_id = nil) ⇒ TransactionSample
Returns a new instance of TransactionSample.
372
373
374
375
376
377
378
|
# File 'lib/new_relic/transaction_sample.rb', line 372
def initialize(time = Time.now.to_f, sample_id = nil)
@sample_id = sample_id || object_id
@start_time = time
@root_segment = create_segment 0.0, "ROOT"
@params = {}
@params[:request_params] = {}
end
|
Instance Attribute Details
Returns the value of attribute params.
369
370
371
|
# File 'lib/new_relic/transaction_sample.rb', line 369
def params
@params
end
|
Returns the value of attribute profile.
367
368
369
|
# File 'lib/new_relic/transaction_sample.rb', line 367
def profile
@profile
end
|
#root_segment ⇒ Object
Returns the value of attribute root_segment.
368
369
370
|
# File 'lib/new_relic/transaction_sample.rb', line 368
def root_segment
@root_segment
end
|
#sample_id ⇒ Object
Returns the value of attribute sample_id.
370
371
372
|
# File 'lib/new_relic/transaction_sample.rb', line 370
def sample_id
@sample_id
end
|
Class Method Details
.close_connections ⇒ Object
353
354
355
356
357
358
359
360
361
362
363
|
# File 'lib/new_relic/transaction_sample.rb', line 353
def close_connections
@@connections ||= {}
@@connections.values.each do |connection|
begin
connection.disconnect!
rescue
end
end
@@connections = {}
end
|
.from_json(json) ⇒ Object
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
|
# File 'lib/new_relic/transaction_sample.rb', line 411
def self.from_json(json)
json = ActiveSupport::JSON.decode(json) if json.is_a?(String)
if json.is_a?(Array)
start_time = json[0].to_f / 1000
custom_params = HashWithIndifferentAccess.new(json[2])
params = {:request_params => HashWithIndifferentAccess.new(json[1]),
:custom_params => custom_params}
cpu_time = custom_params.delete(:cpu_time)
sample_id = nil
params[:cpu_time] = cpu_time.to_f / 1000 if cpu_time
root = json[3]
else
start_time = json["start_time"].to_f
sample_id = json["sample_id"].to_i
params = json["params"]
root = json["root_segment"]
end
sample = TransactionSample.new(start_time, sample_id)
if params
sample.send :params=, HashWithIndifferentAccess.new(params)
end
if root
sample.send :root_segment=, Segment.from_json(root, IDGenerator.new)
end
sample
end
|
.get_connection(config) ⇒ Object
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
|
# File 'lib/new_relic/transaction_sample.rb', line 336
def get_connection(config)
@@connections ||= {}
connection = @@connections[config]
return connection if connection
begin
connection = ActiveRecord::Base.send("#{config[:adapter]}_connection", config)
@@connections[config] = connection
rescue => e
NewRelic::Agent.agent.log.error("Caught exception #{e} trying to get connection to DB for explain. Control: #{config}")
NewRelic::Agent.agent.log.error(e.backtrace.join("\n"))
nil
end
end
|
.obfuscate_sql(sql) ⇒ Object
331
332
333
|
# File 'lib/new_relic/transaction_sample.rb', line 331
def obfuscate_sql(sql)
NewRelic::Agent.instance.obfuscator.call(sql)
end
|
Instance Method Details
534
535
536
537
538
539
540
541
542
543
544
545
546
|
# File 'lib/new_relic/transaction_sample.rb', line 534
def analyze
sample = self
original_path_string = nil
loop do
original_path_string = sample.path_string.to_s
new_sample = sample.dup
new_sample.root_segment = sample.root_segment.dup
new_sample.root_segment.called_segments = analyze_called_segments(root_segment.called_segments)
sample = new_sample
return sample if sample.path_string.to_s == original_path_string
end
end
|
#count_segments ⇒ Object
380
381
382
|
# File 'lib/new_relic/transaction_sample.rb', line 380
def count_segments
@root_segment.count_segments - 1 end
|
#create_segment(relative_timestamp, metric_name, segment_id = nil) ⇒ Object
449
450
451
452
|
# File 'lib/new_relic/transaction_sample.rb', line 449
def create_segment(relative_timestamp, metric_name, segment_id = nil)
raise TypeError.new("Frozen Transaction Sample") if frozen?
NewRelic::TransactionSample::Segment.new(relative_timestamp, metric_name, segment_id)
end
|
459
460
461
|
# File 'lib/new_relic/transaction_sample.rb', line 459
def duration
root_segment.duration
end
|
#each_segment(&block) ⇒ Object
463
464
465
|
# File 'lib/new_relic/transaction_sample.rb', line 463
def each_segment(&block)
@root_segment.each_segment(&block)
end
|
#find_segment(id) ⇒ Object
471
472
473
|
# File 'lib/new_relic/transaction_sample.rb', line 471
def find_segment(id)
@root_segment.find_segment(id)
end
|
454
455
456
457
|
# File 'lib/new_relic/transaction_sample.rb', line 454
def freeze
@root_segment.freeze
super
end
|
#omit_segments_with(regex) ⇒ Object
return a new transaction sample that treats segments with the given regular expression in their name as if they were never called at all. This allows us to strip out segments from traces captured in development environment that would not normally show up in production (like Rails/Application Code Loading)
500
501
502
503
504
505
506
507
508
509
510
511
|
# File 'lib/new_relic/transaction_sample.rb', line 500
def omit_segments_with(regex)
regex = Regexp.new(regex)
sample = TransactionSample.new(@start_time, sample_id)
params.each {|k,v| sample.params[k] = v}
delta = build_segment_with_omissions(sample, 0.0, @root_segment, sample.root_segment, regex)
sample.root_segment.end_trace(@root_segment.exit_timestamp - delta)
sample.profile = self.profile
sample.freeze
end
|
#path_string ⇒ Object
445
446
447
|
# File 'lib/new_relic/transaction_sample.rb', line 445
def path_string
@root_segment.path_string
end
|
#prepare_to_send(options = {}) ⇒ Object
return a new transaction sample that can be sent to the RPM service. this involves potentially one or more of the following options
:explain_sql : run EXPLAIN on all queries whose response times equal the value for this key
(for example :explain_sql => 2.0 would explain everything over 2 seconds. 0.0 would explain everything.)
:keep_backtraces : keep backtraces, significantly increasing size of trace (off by default)
:obfuscate_sql : clear sql fields of potentially sensitive values (higher overhead, better security)
519
520
521
522
523
524
525
526
527
528
529
530
531
532
|
# File 'lib/new_relic/transaction_sample.rb', line 519
def prepare_to_send(options={})
sample = TransactionSample.new(@start_time, sample_id)
sample.params.merge! self.params
begin
build_segment_for_transfer(sample, @root_segment, sample.root_segment, options)
ensure
self.class.close_connections
end
sample.root_segment.end_trace(@root_segment.exit_timestamp)
sample.freeze
end
|
#start_time ⇒ Object
441
442
443
|
# File 'lib/new_relic/transaction_sample.rb', line 441
def start_time
Time.at(@start_time)
end
|
#timestamp ⇒ Object
397
398
399
|
# File 'lib/new_relic/transaction_sample.rb', line 397
def timestamp
@start_time - @@start_time.to_f
end
|
#to_json(options = {}) ⇒ Object
401
402
403
404
405
406
407
408
409
|
# File 'lib/new_relic/transaction_sample.rb', line 401
def to_json(options = {})
map = {:sample_id => @sample_id,
:start_time => @start_time,
:root_segment => @root_segment}
if @params && !@params.empty?
map[:params] = @params
end
map.to_json
end
|
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
|
# File 'lib/new_relic/transaction_sample.rb', line 475
def to_s
s = "Transaction Sample collected at #{start_time}\n"
s << " {\n"
s << " Path: #{params[:path]} \n"
params.each do |k,v|
next if k == :path
s << " #{k}: " <<
case v
when Enumerable then v.map(&:to_s).sort.join("; ")
when String then v
when Float then '%6.3s' % v
else
raise "unexpected value type for #{k}: '#{v}' (#{v.class})"
end << "\n"
end
s << " }\n\n"
s << @root_segment.to_debug_str(0)
end
|
#to_s_compact ⇒ Object
467
468
469
|
# File 'lib/new_relic/transaction_sample.rb', line 467
def to_s_compact
@root_segment.to_s_compact
end
|
#truncate(max) ⇒ Object
384
385
386
387
388
389
390
391
392
393
394
|
# File 'lib/new_relic/transaction_sample.rb', line 384
def truncate(max)
original_count = count_segments
return if original_count <= max
@root_segment.truncate(max-1)
if params[:segment_count].nil?
params[:segment_count] = original_count
end
end
|