Class: Sidekiq::QueueMetrics::Monitor

Inherits:
Object
  • Object
show all
Defined in:
lib/sidekiq_queue_metrics/monitor/monitor.rb

Direct Known Subclasses

JobDeathMonitor, JobSuccessMonitor

Instance Method Summary collapse

Instance Method Details

#monitor(queue) ⇒ Object 



6
7
8
9
10
11
12
13
14
15
16
17
 
# File 'lib/sidekiq_queue_metrics/monitor/monitor.rb', line 6

def monitor(queue)
  stats = existing_stats
  stats[queue] ||= {}

  if stats[queue][status_counter].nil?
    stats[queue][status_counter] = 1
  else
    stats[queue][status_counter] += 1
  end

  Storage.set_stats(stats.to_json)
end