class PrometheusExporter::Instrumentation::SidekiqQueue

Public Class Methods

start(client: nil, frequency: 30) click to toggle source
# File lib/prometheus_exporter/instrumentation/sidekiq_queue.rb, line 5
def self.start(client: nil, frequency: 30)
  client ||= PrometheusExporter::Client.default
  sidekiq_queue_collector = new

  Thread.new do
    loop do
      begin
        client.send_json(sidekiq_queue_collector.collect)
      rescue StandardError => e
        client.logger.error("Prometheus Exporter Failed To Collect Sidekiq Queue metrics #{e}")
      ensure
        sleep frequency
      end
    end
  end
end

Public Instance Methods

collect() click to toggle source
# File lib/prometheus_exporter/instrumentation/sidekiq_queue.rb, line 22
def collect
  {
    type: 'sidekiq_queue',
    queues: collect_queue_stats
  }
end
collect_queue_stats() click to toggle source
# File lib/prometheus_exporter/instrumentation/sidekiq_queue.rb, line 29
def collect_queue_stats
  hostname = Socket.gethostname
  pid = ::Process.pid
  ps = ::Sidekiq::ProcessSet.new

  process = ps.find do |sp|
    sp['hostname'] == hostname && sp['pid'] == pid
  end

  queues = process.nil? ? [] : process['queues']

  ::Sidekiq::Queue.all.map do |queue|
    next unless queues.include? queue.name
    {
      backlog_total: queue.size,
      latency_seconds: queue.latency.to_i,
      labels: { queue: queue.name }
    }
  end.compact
end