class SidekiqQueueStatus::QueueLatency

Constants

DEFAULT_TRESHOLD

Public Instance Methods

max_latency(name) click to toggle source
# File lib/sidekiq_queue_status/queue_latency.rb, line 14
def max_latency(name)
  Hash.new(DEFAULT_TRESHOLD).merge(Metric.config['queue_tresholds'])[name]
end
monitor() click to toggle source
# File lib/sidekiq_queue_status/queue_latency.rb, line 4
def monitor
  queues_with_latency.each do |name, latency|
    error("Queue #{name} above threshold of #{max_latency(name)}s") if latency > max_latency(name)
  end
end
queues_with_latency() click to toggle source
# File lib/sidekiq_queue_status/queue_latency.rb, line 10
def queues_with_latency
  Hash[*Sidekiq::Queue.all.map { |q| [q.name, q.latency.to_i] }.flatten]
end