Contents

# frozen_string_literal: true

require 'rails_autoscale_agent/logger'
require 'sidekiq/api'

module WorkerAdapters
  class Sidekiq
    include RailsAutoscaleAgent::Logger

    def enabled?
      defined?(::Sidekiq)
    end

    # TODO: specs
    def collect!(store)
      log_msg = String.new('Sidekiq latency ')

      ::Sidekiq::Queue.all.each do |queue|
        latency_ms = (queue.latency * 1000).ceil
        store.push latency_ms, Time.now, queue.name
        log_msg << "#{queue.name}=#{latency_ms} "
      end

      logger.debug log_msg
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
rails_autoscale_agent-0.6.0	lib/rails_autoscale_agent/worker_adapters/sidekiq.rb