class NewRelic::Agent::TransactionEventAggregator

Public Instance Methods

record(priority: nil, event: nil, &blk) click to toggle source
# File lib/new_relic/agent/transaction_event_aggregator.rb, line 18
def record(priority: nil, event: nil, &blk)
  unless event || priority && blk
    raise ArgumentError, 'Expected priority and block, or event'
  end

  return unless enabled?

  @lock.synchronize do
    @buffer.append(priority: priority, event: event, &blk)
    notify_if_full
  end
end

Private Instance Methods

after_harvest(metadata) click to toggle source
# File lib/new_relic/agent/transaction_event_aggregator.rb, line 33
def after_harvest(metadata)
  return unless enabled?

  record_sampling_rate(metadata)
end
record_sampling_rate(metadata) click to toggle source
# File lib/new_relic/agent/transaction_event_aggregator.rb, line 39
def record_sampling_rate(metadata) # THREAD_LOCAL_ACCESS
  NewRelic::Agent.logger.debug('Sampled %d / %d (%.1f %%) requests this cycle, %d / %d (%.1f %%) since startup' % [
    metadata[:captured],
    metadata[:seen],
    (metadata[:captured].to_f / metadata[:seen] * 100.0),
    metadata[:captured_lifetime],
    metadata[:seen_lifetime],
    (metadata[:captured_lifetime].to_f / metadata[:seen_lifetime] * 100.0)
  ])

  engine = NewRelic::Agent.instance.stats_engine
  engine.tl_record_supportability_metric_count('TransactionEventAggregator/requests', metadata[:seen])
  engine.tl_record_supportability_metric_count('TransactionEventAggregator/samples', metadata[:captured])
end