class Moxprox::Node

Public Instance Methods

machine(id) click to toggle source
# File lib/moxprox/node.rb, line 3
def machine(id)
  Machine.new(self, id)
end
request(path, method = "get", query = {}) click to toggle source
# File lib/moxprox/node.rb, line 7
def request(path, method = "get", query = {})
  cluster.request("nodes/#{name}/#{path}", method, query)
end
task_status(upid) click to toggle source
# File lib/moxprox/node.rb, line 11
def task_status(upid)
  res = request("tasks/#{upid}/status")
  status = (res["exitstatus"] || res["status"] || "error").downcase.to_sym
  logger.debug "status of task #{upid}: #{status}"
end
wait_for_task(upid) { |status| ... } click to toggle source
# File lib/moxprox/node.rb, line 17
def wait_for_task(upid, &block)
  while (status = task_status(upid)) == :running
    sleep 1
  end
  yield status
end

Private Instance Methods

logger() click to toggle source
# File lib/moxprox/node.rb, line 25
def logger
  cluster.send(:logger)
end