Contents

require_relative 'monitor'

module Sidekiq::QueueMetrics
  class JobSuccessMonitor < Monitor
    def call(worker, job, queue)
      yield if block_given?
      monitor(queue)
    end

    def status_counter
      'processed'
    end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
sidekiq_queue_metrics-2.1.1	lib/sidekiq_queue_metrics/monitor/job_success_monitor.rb
sidekiq_queue_metrics-2.1	lib/sidekiq_queue_metrics/monitor/job_success_monitor.rb
sidekiq_queue_metrics-2.0	lib/sidekiq_queue_metrics/monitor/job_success_monitor.rb
sidekiq_queue_metrics-1.0	lib/sidekiq_queue_metrics/monitor/job_success_monitor.rb
sidekiq_queue_metrics-0.0.4	lib/sidekiq_queue_metrics/monitor/job_success_monitor.rb
sidekiq_queue_metrics-0.0.3	lib/sidekiq_queue_metrics/monitor/job_success_monitor.rb
sidekiq_queue_metrics-0.0.2	lib/sidekiq_queue_metrics/monitor/job_success_monitor.rb