Merge pull request ManageIQ#16198 from agrare/containers_inventory_co…

…llector_worker

Add an inventory_collector_worker base class

app/models/manageiq/providers/base_manager/inventory_collector_worker.rb

@@ -0,0 +1,31 @@
+class ManageIQ::Providers::BaseManager::InventoryCollectorWorker < MiqWorker
+  require_nested :Runner
+
+  include PerEmsWorkerMixin
+
+  self.required_roles = "ems_inventory"
+
+  def self.has_required_role?
+    !worker_settings[:disabled]
+  end
+
+  def friendly_name
+    @friendly_name ||= begin
+      ems = ext_management_system
+      if ems.nil?
+        queue_name.titleize
+      else
+        _("Inventory Collector for %{table}: %{name}") % {:table => ui_lookup(:table => "ext_management_systems"),
+                                                          :name  => ems.name}
+      end
+    end
+  end
+
+  def self.ems_class
+    parent
+  end
+
+  def self.normalized_type
+    @normalized_type ||= "ems_inventory_collector_worker"
+  end
+end

app/models/manageiq/providers/base_manager/inventory_collector_worker/runner.rb

@@ -0,0 +1,16 @@
+require 'thread'
+
+class ManageIQ::Providers::BaseManager::InventoryCollectorWorker::Runner < ::MiqWorker::Runner
+  OPTIONS_PARSER_SETTINGS = ::MiqWorker::Runner::OPTIONS_PARSER_SETTINGS + [
+    [:ems_id, 'EMS Instance ID', String],
+  ]
+
+  def after_initialize
+    @ems = ExtManagementSystem.find(@cfg[:ems_id])
+    do_exit("Unable to find instance for EMS ID [#{@cfg[:ems_id]}].", 1) if @ems.nil?
+    do_exit("EMS ID [#{@cfg[:ems_id]}] failed authentication check.", 1) unless @ems.authentication_check.first
+  end
+
+  attr_reader :ems
+  private :ems
+end

config/settings.yml

@@ -1065,6 +1065,10 @@
     :agent_coordinator_worker:
       :heartbeat_timeout: 30.minutes
       :poll: 30.seconds
+    :ems_inventory_collector_worker:
+      :disabled: true
+      :nice_delta: 1
+      :poll: 5.seconds
     :ems_refresh_core_worker:
       :poll: 1.seconds
       :nice_delta: 1