class Invoker::IPC::Message::ListResponse

Public Class Methods

from_workers(workers) click to toggle source
# File lib/invoker/ipc/message/list_response.rb, line 15
def self.from_workers(workers)
  process_array = []
  Invoker.config.processes.each do |process|
    worker_attrs = {
      shell_command: process.cmd,
      process_name: process.label,
      dir: process.dir,
      port: process.port
    }
    if worker = workers[process.label]
      worker_attrs.update(pid: worker.pid)
    end
    process_array << worker_attrs
  end

  new(processes: process_array)
end
new(options) click to toggle source
# File lib/invoker/ipc/message/list_response.rb, line 7
def initialize(options)
  self.processes = []
  process_array = options[:processes] || options['processes']
  process_array.each do |process_hash|
    processes << Process.new(process_hash)
  end
end