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