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