You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
26 lines
515 B
26 lines
515 B
4 years ago
|
# frozen_string_literal: true
|
||
|
|
|
||
|
|
class Admin::SystemCheck::SidekiqProcessCheck < Admin::SystemCheck::BaseCheck
|
||
|
|
SIDEKIQ_QUEUES = %w(
|
||
|
|
default
|
||
|
|
push
|
||
|
|
mailers
|
||
|
|
pull
|
||
|
|
scheduler
|
||
|
|
).freeze
|
||
|
|
|
||
|
|
def pass?
|
||
|
|
missing_queues.empty?
|
||
|
|
end
|
||
|
|
|
||
|
|
def message
|
||
|
|
Admin::SystemCheck::Message.new(:sidekiq_process_check, missing_queues.join(', '))
|
||
|
|
end
|
||
|
|
|
||
|
|
private
|
||
|
|
|
||
|
|
def missing_queues
|
||
|
|
@missing_queues ||= Sidekiq::ProcessSet.new.reduce(SIDEKIQ_QUEUES) { |queues, process| queues - process['queues'] }
|
||
|
|
end
|
||
|
|
end
|