class PrometheusExporter::Server::PumaCollector
Constants
- MAX_PUMA_METRIC_AGE
- PUMA_GAUGES
Public Class Methods
new()
click to toggle source
# File lib/prometheus_exporter/server/puma_collector.rb, line 16 def initialize @puma_metrics = [] end
Public Instance Methods
collect(obj)
click to toggle source
# File lib/prometheus_exporter/server/puma_collector.rb, line 53 def collect(obj) now = ::Process.clock_gettime(::Process::CLOCK_MONOTONIC) obj["created_at"] = now @puma_metrics.delete_if do |current| (obj["pid"] == current["pid"] && obj["hostname"] == current["hostname"]) || (current["created_at"] + MAX_PUMA_METRIC_AGE < now) end @puma_metrics << obj end
metrics()
click to toggle source
# File lib/prometheus_exporter/server/puma_collector.rb, line 24 def metrics return [] if @puma_metrics.length == 0 metrics = {} @puma_metrics.map do |m| labels = {} if m["phase"] labels.merge!(phase: m["phase"]) end if m["custom_labels"] labels.merge!(m["custom_labels"]) end if m["metric_labels"] labels.merge!(m["metric_labels"]) end PUMA_GAUGES.map do |k, help| k = k.to_s if v = m[k] g = metrics[k] ||= PrometheusExporter::Metric::Gauge.new("puma_#{k}", help) g.observe(v, labels) end end end metrics.values end
type()
click to toggle source
# File lib/prometheus_exporter/server/puma_collector.rb, line 20 def type "puma" end