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