class HealthMonitor::Providers::Sidekiq::Configuration

Constants

DEFAULT_LATENCY_TIMEOUT
DEFAULT_QUEUES_SIZE
DEFAULT_QUEUE_NAME

Attributes

queues[R]

Public Class Methods

new() click to toggle source
# File lib/health_monitor/providers/sidekiq.rb, line 18
def initialize
  @queues = {}
  @queues[DEFAULT_QUEUE_NAME] = { latency: DEFAULT_LATENCY_TIMEOUT, queue_size: DEFAULT_QUEUES_SIZE }
end

Public Instance Methods

add_queue_configuration(queue_name, latency: DEFAULT_LATENCY_TIMEOUT, queue_size: DEFAULT_QUEUES_SIZE) click to toggle source
# File lib/health_monitor/providers/sidekiq.rb, line 43
def add_queue_configuration(queue_name, latency: DEFAULT_LATENCY_TIMEOUT, queue_size: DEFAULT_QUEUES_SIZE)
  raise SidekiqException.new('Queue name is mandatory') if queue_name.blank?

  queues[queue_name] = { latency: latency, queue_size: queue_size }
end
default_queue() click to toggle source
# File lib/health_monitor/providers/sidekiq.rb, line 39
def default_queue
  queues[DEFAULT_QUEUE_NAME]
end
latency() click to toggle source
# File lib/health_monitor/providers/sidekiq.rb, line 27
def latency
  default_queue[:latency]
end
latency=(value) click to toggle source
# File lib/health_monitor/providers/sidekiq.rb, line 23
def latency=(value)
  default_queue[:latency] = value
end
queue_size() click to toggle source
# File lib/health_monitor/providers/sidekiq.rb, line 35
def queue_size
  default_queue[:queue_size]
end
queue_size=(value) click to toggle source
# File lib/health_monitor/providers/sidekiq.rb, line 31
def queue_size=(value)
  default_queue[:queue_size] = value
end