Class: PrometheusExporter::Server::Collector

Inherits:
CollectorBase show all
Defined in:
lib/prometheus_exporter/server/collector.rb

Constant Summary collapse

MAX_PROCESS_METRIC_AGE = 
60
PROCESS_GAUGES = 
{
  heap_free_slots: "Free ruby heap slots",
  heap_live_slots: "Used ruby heap slots",
  v8_heap_size: "Total JavaScript V8 heap size (bytes)",
  v8_used_heap_size: "Total used JavaScript V8 heap size (bytes)",
  v8_physical_size: "Physical size consumed by V8 heaps",
  v8_heap_count: "Number of V8 contexts running",
  rss: "Total RSS used by process",
}
PROCESS_COUNTERS = 
{
  major_gc_count: "Major GC operations by process",
  minor_gc_count: "Minor GC operations by process",
  total_allocated_objects: "Total number of allocateds objects by process",
}

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Collector

Returns a new instance of Collector.



23
24
25
26
27
28
29
30
31
 
# File 'lib/prometheus_exporter/server/collector.rb', line 23

def initialize
  @process_metrics = []
  @metrics = {}
  @mutex = Mutex.new
  @collectors = {}
  register_collector(WebCollector.new)
  register_collector(ProcessCollector.new)
  register_collector(SidekiqCollector.new)
end

Instance Method Details

#process(str) ⇒ Object 



37
38
39
40
41
42
43
44
45
46
47
48
49
50
 
# File 'lib/prometheus_exporter/server/collector.rb', line 37

def process(str)
  obj = JSON.parse(str)
  @mutex.synchronize do
    if collector = @collectors[obj["type"]]
      collector.observe(obj)
    else
      metric = @metrics[obj["name"]]
      if !metric
        metric = register_metric_unsafe(obj)
      end
      metric.observe(obj["value"], obj["keys"])
    end
  end
end

#prometheus_metrics_text ⇒ Object 



52
53
54
55
56
57
 
# File 'lib/prometheus_exporter/server/collector.rb', line 52

def prometheus_metrics_text
  @mutex.synchronize do
    (@metrics.values + @collectors.values.map(&:metrics).flatten)
      .map(&:to_prometheus_text).join("\n")
  end
end

#register_collector(collector) ⇒ Object 



33
34
35
 
# File 'lib/prometheus_exporter/server/collector.rb', line 33

def register_collector(collector)
  @collectors[collector.type] = collector
end