Class: WorkerRoulette::QueueDepth

Inherits:
Object
  • Object
show all
Includes:
QueueMetricTracker
Defined in:
lib/worker_roulette/queue_depth.rb

Instance Method Summary collapse

Methods included from QueueMetricTracker

#calculate_stats, #calculator, #channel, #config, configure, #enabled?, #granularity, included, ip_address, #message, track_all, #tracker_send

Instance Method Details

#track(sender, work_orders, remaining) ⇒ Object 



7
8
9
10
11
12
13
 
# File 'lib/worker_roulette/queue_depth.rb', line 7

def track(sender, work_orders, remaining)
  return unless enabled?

  if value = calculate_stats(:queue_depth, remaining)
    tracker_send(message("queue_depth", channel(sender), value))
  end
end