Sha256: dba29bf5ae3fb2e6e4fbfdb5e2ad478ca1dbfe6d27fb4ba698f40a5b18fd672a
Contents?: true
Size: 1.7 KB
Versions: 21
Compression:
Stored size: 1.7 KB
Contents
# -*- ruby -*-
# encoding: utf-8
# This file is distributed under New Relic's license terms.
# See https://github.com/newrelic/rpm/blob/master/LICENSE for complete details.
require 'newrelic_rpm' unless defined?( NewRelic )
require 'new_relic/agent' unless defined?( NewRelic::Agent )
require 'new_relic/agent/event_aggregator'
module NewRelic
module Agent
class TransactionEventAggregator < EventAggregator
named :TransactionEventAggregator
capacity_key :'analytics_events.max_samples_stored'
enabled_key :'analytics_events.enabled'
def append event=nil, &blk
raise ArgumentError, "Expected argument or block, but received both" if event && blk
return unless enabled?
@lock.synchronize do
@buffer.append event, &blk
notify_if_full
end
end
private
def after_harvest metadata
return unless enabled?
record_sampling_rate metadata
end
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
end
end
end
Version data entries
21 entries across 21 versions & 2 rubygems