26 lines
515 B
Ruby
26 lines
515 B
Ruby
# 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
|