Contents

# frozen_string_literal: true

module PrometheusExporter::Server
  class ResqueCollector < TypeCollector
    MAX_METRIC_AGE = 30
    RESQUE_GAUGES = {
      processed_jobs: "Total number of processed Resque jobs.",
      failed_jobs: "Total number of failed Resque jobs.",
      pending_jobs: "Total number of pending Resque jobs.",
      queues: "Total number of Resque queues.",
      workers: "Total number of Resque workers running.",
      working: "Total number of Resque workers working."
    }

    def initialize
      @resque_metrics = MetricsContainer.new(ttl: MAX_METRIC_AGE)
      @gauges = {}
    end

    def type
      "resque"
    end

    def metrics
      return [] if resque_metrics.length == 0

      resque_metrics.map do |metric|
        labels = metric.fetch("custom_labels", {})

        RESQUE_GAUGES.map do |name, help|
          name = name.to_s
          if value = metric[name]
            gauge = gauges[name] ||= PrometheusExporter::Metric::Gauge.new("resque_#{name}", help)
            gauge.observe(value, labels)
          end
        end
      end

      gauges.values
    end

    def collect(object)
      @resque_metrics << object
    end

    private

    attr_reader :resque_metrics, :gauges
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
prometheus_exporter-2.1.1	lib/prometheus_exporter/server/resque_collector.rb
prometheus_exporter-2.1.0	lib/prometheus_exporter/server/resque_collector.rb