Class: PrometheusExporter::Server::Collector

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

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Collector

Returns a new instance of Collector.



7
8
9
10
11
 
# File 'lib/prometheus_exporter/server/collector.rb', line 7

def initialize
  @metrics = {}
  @buffer = []
  @mutex = Mutex.new
end

Instance Method Details

#process(obj) ⇒ Object 



13
14
15
16
17
18
19
20
21
 
# File 'lib/prometheus_exporter/server/collector.rb', line 13

def process(obj)
  @mutex.synchronize do
    metric = @metrics[obj["name"]]
    if !metric
      metric = register_metric_unsafe(obj)
    end
    metric.observe(obj["value"], obj["keys"])
  end
end

#prometheus_metrics_text ⇒ Object 



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

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

#register_metric(metric) ⇒ Object 



29
30
31
32
33
 
# File 'lib/prometheus_exporter/server/collector.rb', line 29

def register_metric(metric)
  @mutex.synchronize do
    @metrics << metric
  end
end