statsd_queue_size.rb

# frozen_string_literal: true

class Sidekiq::Middleware::Server::StatsdQueueSize
  def initialize(_options = nil)
    @statsd = Sidekiq::Pro.metrics
  end

  def call(_worker, _msg, queue)
    @statsd.gauge "queue.#{queue}.size", Sidekiq::Queue.new(queue).size

    yield
  end
end