class HealthMonitor::Providers::Sidekiq::Configuration

Constants

DEFAULT_LATENCY_TIMEOUT
DEFAULT_QUEUES_SIZE
DEFAULT_QUEUE_NAME
DEFAULT_RETRY_CHECK

Attributes

maximum_amount_of_retries[RW]
queues[R]

Public Class Methods

new(provider) click to toggle source
# File lib/health_monitor/providers/sidekiq.rb, line 20
def initialize(provider)
  super

  @maximum_amount_of_retries = DEFAULT_RETRY_CHECK

  @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 49
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 45
def default_queue
  queues[DEFAULT_QUEUE_NAME]
end
latency() click to toggle source
# File lib/health_monitor/providers/sidekiq.rb, line 33
def latency
  default_queue[:latency]
end
latency=(value) click to toggle source
# File lib/health_monitor/providers/sidekiq.rb, line 29
def latency=(value)
  default_queue[:latency] = value
end
queue_size() click to toggle source
# File lib/health_monitor/providers/sidekiq.rb, line 41
def queue_size
  default_queue[:queue_size]
end
queue_size=(value) click to toggle source
# File lib/health_monitor/providers/sidekiq.rb, line 37
def queue_size=(value)
  default_queue[:queue_size] = value
end