Sha256: d59bacc153306940a9b33804b3cbc3b9ce41c70e0cded8e2d526ddc052a40f00
Contents?: true
Size: 1.37 KB
Versions: 14
Compression:
Stored size: 1.37 KB
Contents
# frozen_string_literal: true
module InstrumentAllTheThings
module Instrumentors
DEFAULT_GC_STATS_OPTIONS = {
diffed_stats: %i[
total_allocated_pages
total_allocated_objects
count
].freeze,
}.freeze
# This is to make it easier to spec since other
# gems may call this
GC_STAT_GETTER = -> { GC.stat }
GC_STATS_WRAPPER = lambda do |opts, context|
opts = if opts == true
DEFAULT_GC_STATS_OPTIONS
else
DEFAULT_GC_STATS_OPTIONS.merge(opts)
end
report_value = proc do |klass, stat_name, value|
InstrumentAllTheThings.stat_reporter.histogram(
context.stats_name(klass) + ".#{stat_name}_change",
value,
)
end
lambda do |klass, next_blk, actual_code|
starting_values = GC_STAT_GETTER.call.slice(*opts[:diffed_stats])
next_blk.call(klass, actual_code).tap do
new_values = GC_STAT_GETTER.call.slice(*opts[:diffed_stats])
diff = new_values.merge(starting_values) do |_, new_value, starting_value|
new_value - starting_value
end
if (span = InstrumentAllTheThings.tracer.active_span)
span.set_tags(IATT.to_tracer_tags(diff, 'gc_stats'))
end
diff.each { |s, v| report_value.call(klass, s, v) }
end
end
end
end
end
Version data entries
14 entries across 14 versions & 1 rubygems