Sha256: 648fff6e61a842f815c2d18189d0e95c5d913bfff5d52e5e0acd11616f0bee18
Contents?: true
Size: 826 Bytes
Versions: 10
Compression:
Stored size: 826 Bytes
Contents
# frozen_string_literal: true
# collects stats from resque
module PrometheusExporter::Instrumentation
class Resque < PeriodicStats
def self.start(client: nil, frequency: 30)
resque_collector = new
client ||= PrometheusExporter::Client.default
worker_loop do
client.send_json(resque_collector.collect)
end
super
end
def collect
metric = {}
metric[:type] = "resque"
collect_resque_stats(metric)
metric
end
def collect_resque_stats(metric)
info = ::Resque.info
metric[:processed_jobs] = info[:processed]
metric[:failed_jobs] = info[:failed]
metric[:pending_jobs] = info[:pending]
metric[:queues] = info[:queues]
metric[:worker] = info[:workers]
metric[:working] = info[:working]
end
end
end
Version data entries
10 entries across 10 versions & 1 rubygems