Class: Appsignal::Probes::MriProbe

Inherits:
Object
  • Object
show all
Includes:
Helpers
Defined in:
lib/appsignal/probes/mri.rb

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(appsignal: Appsignal, gc_profiler: Appsignal::GarbageCollection.profiler) ⇒ MriProbe

Returns a new instance of MriProbe.



11
12
13
14
15
 
# File 'lib/appsignal/probes/mri.rb', line 11

def initialize(appsignal: Appsignal, gc_profiler: Appsignal::GarbageCollection.profiler)
  Appsignal.logger.debug("Initializing VM probe")
  @appsignal = appsignal
  @gc_profiler = gc_profiler
end

Class Method Details

.dependencies_present? ⇒ Boolean

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Returns:

  • (Boolean) 


7
8
9
 
# File 'lib/appsignal/probes/mri.rb', line 7

def self.dependencies_present?
  defined?(::RubyVM) && ::RubyVM.respond_to?(:stat)
end

Instance Method Details

#call ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future. 



18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
 
# File 'lib/appsignal/probes/mri.rb', line 18

def call
  stat = RubyVM.stat

  constant_cache_invalidations = stat[:constant_cache_invalidations]
  if constant_cache_invalidations
    set_gauge_with_hostname(
      "ruby_vm",
      constant_cache_invalidations,
      :metric => :constant_cache_invalidations
    )
  end

  constant_cache_misses = stat[:constant_cache_misses]
  if constant_cache_misses
    set_gauge_with_hostname(
      "ruby_vm",
      constant_cache_misses,
      :metric => :constant_cache_misses
    )
  end

  class_serial = stat[:class_serial]
  if class_serial
    set_gauge_with_hostname("ruby_vm", class_serial, :metric => :class_serial)
  end

  global_constant_state =
    stat[:constant_cache] ? stat[:constant_cache].values.sum : stat[:global_constant_state]
  if global_constant_state
    set_gauge_with_hostname(
      "ruby_vm",
      global_constant_state,
      :metric => :global_constant_state
    )
  end

  set_gauge_with_hostname("thread_count", Thread.list.size)
  if Appsignal::GarbageCollection.enabled?
    gauge_delta(:gc_time, @gc_profiler.total_time) do |gc_time|
      set_gauge_with_hostname("gc_time", gc_time) if gc_time > 0
    end
  end

  gc_stats = GC.stat
  gauge_delta(
    :allocated_objects,
    gc_stats[:total_allocated_objects] || gc_stats[:total_allocated_object]
  ) do |allocated_objects|
    set_gauge_with_hostname("allocated_objects", allocated_objects)
  end

  gauge_delta(:gc_count, GC.count) do |gc_count|
    set_gauge_with_hostname("gc_count", gc_count, :metric => :gc_count)
  end
  gauge_delta(:minor_gc_count, gc_stats[:minor_gc_count]) do |minor_gc_count|
    set_gauge_with_hostname("gc_count", minor_gc_count, :metric => :minor_gc_count)
  end
  gauge_delta(:major_gc_count, gc_stats[:major_gc_count]) do |major_gc_count|
    set_gauge_with_hostname("gc_count", major_gc_count, :metric => :major_gc_count)
  end

  set_gauge_with_hostname("heap_slots", gc_stats[:heap_live_slots] || gc_stats[:heap_live_slot], :metric => :heap_live)
  set_gauge_with_hostname("heap_slots", gc_stats[:heap_free_slots] || gc_stats[:heap_free_slot], :metric => :heap_free)
end