Contents

require 'sidekiq'
require 'sidekiq_queue_metrics/storage'

module Sidekiq::QueueMetrics
  class Monitor
    def monitor(queue)
      Storage.increment_stat(queue, status_counter)
    end

    protected def status_counter
      fail 'This method should be implemented by child monitors'
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
sidekiq_queue_metrics-3.0.0	lib/sidekiq_queue_metrics/monitor/monitor.rb