Contents

require 'sidekiq/api'
require 'roo_on_rails/sidekiq/queue_latency'
require 'roo_on_rails/sidekiq/process_scaling'
require 'roo_on_rails/statsd'

module RooOnRails
  module Sidekiq
    class MetricsWorker
      include ::Sidekiq::Worker

      sidekiq_options queue: 'monitoring', retry: false

      def perform
        RooOnRails.statsd.batch do |stats|
          queues = ::Sidekiq::Queue.all.map { |q| QueueLatency.new(q) }
          queue_stats(stats, queues)
          process_stats(stats, queues)
        end
      end

      private

      def queue_stats(stats, queues)
        queues.each do |queue|
          tags = ["queue:#{queue.name}"]
          stats.gauge('jobs.queue.size', queue.size, tags: tags)
          stats.gauge('jobs.queue.latency', queue.latency, tags: tags)
          stats.gauge('jobs.queue.normalised_latency', queue.normalised_latency, tags: tags)
        end
      end

      def process_stats(stats, queues)
        process_stats = ProcessScaling.new(queues)
        stats.gauge('jobs.processes.max_normalised_latency', process_stats.max_normalised_latency)
        stats.gauge('jobs.processes.requested', process_stats.requested_processes)
        stats.gauge('jobs.processes.current', process_stats.current_processes)
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
roo_on_rails-1.7.0	lib/roo_on_rails/sidekiq/metrics_worker.rb
roo_on_rails-1.6.0	lib/roo_on_rails/sidekiq/metrics_worker.rb
roo_on_rails-1.5.0	lib/roo_on_rails/sidekiq/metrics_worker.rb