class RooOnRails::Sidekiq::QueueLatency
Attributes
queue[R]
Public Class Methods
new(queue)
click to toggle source
# File lib/roo_on_rails/sidekiq/queue_latency.rb, line 19 def initialize(queue) @queue = queue end
queues()
click to toggle source
# File lib/roo_on_rails/sidekiq/queue_latency.rb, line 13 def self.queues ::Sidekiq::Queue.all.each_with_object([]) do |q, array| array << new(q) if Settings.queues.include?(q.name.to_s) end end
Public Instance Methods
normalised_latency()
click to toggle source
# File lib/roo_on_rails/sidekiq/queue_latency.rb, line 23 def normalised_latency permitted_latency = Settings.permitted_latency_values[queue.name] return queue.latency.fdiv(permitted_latency).round(3) if permitted_latency raise("Cannot determine permitted latency for queue #{queue.name}") end