class NewRelic::Agent::Stats
Constants
- SKIP_MARSHALLING
Attributes
apdex_f[RW]
apdex_s[RW]
apdex_t[RW]
call_count[RW]
max_call_time[RW]
min_call_time[RW]
sum_of_squares[RW]
total_call_time[RW]
total_exclusive_time[RW]
Public Class Methods
new()
click to toggle source
# File lib/new_relic/agent/stats.rb, line 17 def initialize @lock = Mutex.new reset end
Public Instance Methods
==(other)
click to toggle source
# File lib/new_relic/agent/stats.rb, line 125 def ==(other) other.class == self.class && ( @min_call_time == other.min_call_time && @max_call_time == other.max_call_time && @total_call_time == other.total_call_time && @total_exclusive_time == other.total_exclusive_time && @sum_of_squares == other.sum_of_squares && @call_count == other.call_count ) end
hash_merge(hash)
click to toggle source
# File lib/new_relic/agent/stats.rb, line 52 def hash_merge(hash) @call_count = hash[:count] if hash[:count] @total_call_time = hash[:total] if hash[:total] @total_exclusive_time = hash[:total] if hash[:total] @min_call_time = hash[:min] if hash[:min] @max_call_time = hash[:max] if hash[:max] @sum_of_squares = hash[:sum_of_squares] if hash[:sum_of_squares] self end
increment_count(value = 1)
click to toggle source
increments the call_count
by one
# File lib/new_relic/agent/stats.rb, line 112 def increment_count(value = 1) @lock.synchronize { @call_count += value } end
inspect_full()
click to toggle source
Concerned about implicit usage of inspect relying on stats format, so putting back a version to get full inspection as separate method
# File lib/new_relic/agent/stats.rb, line 118 def inspect_full variables = instance_variables.map do |ivar| "#{ivar.to_s}=#{instance_variable_get(ivar).inspect}" end.join(' ') "#<NewRelic::Agent::Stats #{variables}>" end
is_reset?()
click to toggle source
# File lib/new_relic/agent/stats.rb, line 31 def is_reset? call_count == 0 && total_call_time == 0.0 && total_exclusive_time == 0.0 end
marshal_dump()
click to toggle source
Override marshalling methods to exclude @lock from being included in marshalled data
# File lib/new_relic/agent/stats.rb, line 159 def marshal_dump instance_variables.each_with_object({}) do |name, instance_copy| next if SKIP_MARSHALLING.include?(name) instance_copy[name] = instance_variable_get(name) end end
marshal_load(marshalled_data)
click to toggle source
# File lib/new_relic/agent/stats.rb, line 167 def marshal_load(marshalled_data) marshalled_data.each do |name, value| instance_variable_set(name, value) unless SKIP_MARSHALLING.include?(name) end # since the lock is excluded when marshalling, create a new lock when loading marshalled data @lock = Mutex.new end
merge(other_stats)
click to toggle source
# File lib/new_relic/agent/stats.rb, line 35 def merge(other_stats) stats = self.clone stats.merge!(other_stats) end
merge!(other)
click to toggle source
# File lib/new_relic/agent/stats.rb, line 40 def merge!(other) @lock.synchronize do @min_call_time = other.min_call_time if min_time_less?(other) @max_call_time = other.max_call_time if other.max_call_time > max_call_time @total_call_time += other.total_call_time @total_exclusive_time += other.total_exclusive_time @sum_of_squares += other.sum_of_squares @call_count += other.call_count end self end
record(value = nil, aux = nil) { |self| ... }
click to toggle source
# File lib/new_relic/agent/stats.rb, line 77 def record(value = nil, aux = nil, &blk) if blk yield(self) else case value when Numeric aux ||= value self.record_data_point(value, aux) when :apdex_s, :apdex_t, :apdex_f self.record_apdex(value, aux) when NewRelic::Agent::Stats self.merge!(value) end end end
record_apdex(bucket, apdex_t)
click to toggle source
# File lib/new_relic/agent/stats.rb, line 142 def record_apdex(bucket, apdex_t) @lock.synchronize do case bucket when :apdex_s then @call_count += 1 when :apdex_t then @total_call_time += 1 when :apdex_f then @total_exclusive_time += 1 end if apdex_t @min_call_time = apdex_t @max_call_time = apdex_t else ::NewRelic::Agent.logger.warn("Attempted to set apdex_t to #{apdex_t.inspect}, backtrace = #{caller.join("\n")}") end end end
record_data_point(value, exclusive_time = value)
click to toggle source
record a single data point into the statistical gatherer. The gatherer will aggregate all data points collected over a specified period and upload its data to the NewRelic
server
# File lib/new_relic/agent/stats.rb, line 96 def record_data_point(value, exclusive_time = value) @lock.synchronize do @call_count += 1 @total_call_time += value @min_call_time = value if value < @min_call_time || @call_count == 1 @max_call_time = value if value > @max_call_time @total_exclusive_time += exclusive_time @sum_of_squares += (value * value) end self end
Also aliased as: trace_call
reset()
click to toggle source
# File lib/new_relic/agent/stats.rb, line 22 def reset @call_count = 0 @total_call_time = 0.0 @total_exclusive_time = 0.0 @min_call_time = 0.0 @max_call_time = 0.0 @sum_of_squares = 0.0 end
to_json(*_)
click to toggle source
# File lib/new_relic/agent/stats.rb, line 62 def to_json(*_) { 'call_count' => call_count.to_i, 'min_call_time' => min_call_time.to_f, 'max_call_time' => max_call_time.to_f, 'total_call_time' => total_call_time.to_f, 'total_exclusive_time' => total_exclusive_time.to_f, 'sum_of_squares' => sum_of_squares.to_f }.to_json(*_) end
to_s()
click to toggle source
# File lib/new_relic/agent/stats.rb, line 73 def to_s "[#{'%2i' % call_count.to_i} calls #{'%.4f' % total_call_time.to_f}s / #{'%.4f' % total_exclusive_time.to_f}s ex]" end
Protected Instance Methods
min_time_less?(other)
click to toggle source
# File lib/new_relic/agent/stats.rb, line 177 def min_time_less?(other) (other.min_call_time < min_call_time && other.call_count > 0) || call_count == 0 end