app/models/miq_worker/deployment_per_worker.rb
class MiqWorker
module DeploymentPerWorker
extend ActiveSupport::Concern
def create_container_objects
ContainerOrchestrator.new.create_deployment(worker_deployment_name) do |definition|
configure_worker_deployment(definition, 1)
definition[:spec][:template][:spec][:containers].first[:env] << {:name => "EMS_IDS", :value => Array.wrap(self.class.ems_id_from_queue_name(queue_name)).join(",")}
end
end
def delete_container_objects
ContainerOrchestrator.new.delete_deployment(worker_deployment_name)
end
def stop_container
delete_container_objects
end
end
end