Class: Delayed::Monitor

Inherits:

Object

• Object
• Delayed::Monitor

Includes:

Runnable

Defined in:

lib/delayed/monitor.rb

Constant Summary

METRICS =

%w(
  count
  future_count
  locked_count
  erroring_count
  failed_count
  max_lock_age
  max_age
  working_count
  workable_count
  alert_age_percent
).freeze

Instance Method Summary

• #initialize ⇒ Monitor constructor

  A new instance of Monitor.

• #run! ⇒ Object

Methods included from Runnable

#start

Constructor Details

#initialize ⇒ Monitor

Returns a new instance of Monitor.

# File 'lib/delayed/monitor.rb', line 20

def initialize
  @jobs = Job.group(priority_case_statement).group(:queue)
  @jobs = @jobs.where(queue: Worker.queues) if Worker.queues.any?
end

Instance Method Details

#run! ⇒ Object

# File 'lib/delayed/monitor.rb', line 25

def run!
  ActiveSupport::Notifications.instrument('delayed.monitor.run', default_tags) do
    METRICS.each { |metric| emit_metric!(metric) }
  end
  interruptable_sleep(sleep_delay)
end