Sha256: 8702bede19af8e4d9621d77e0be4ee5ced9df20fd82fea8e9726cae383c29218
Contents?: true
Size: 1.7 KB
Versions: 4
Compression:
Stored size: 1.7 KB
Contents
require 'eventmachine'
module Rancher
module Api
module Helpers
module Model
class RancherWaitTimeOutError < StandardError; end
class RancherModelError < StandardError; end
class RancherActionNotAvailableError < StandardError; end
TIMEOUT_LIMIT = 900
def self_url
links['self']
end
def reload
assign_attributes(self.class.find(id).attributes)
end
def run(action, data: {})
url = actions[action.to_s]
raise RancherActionNotAvailableError, "Available actions: '#{actions.inspect}'" if url.blank?
handle_response(self.class.post(url, data))
end
def handle_response(response)
case response
when Her::Collection
response
when Her::Model
raise RancherModelError, response.inspect if response.type.eql?('error')
response
else
raise RancherModelError, response.inspect
end
end
def wait_for_state(desired_state)
EM.run do
EM.add_timer(TIMEOUT_LIMIT) do
raise RancherWaitTimeOutError, "Timeout while waiting for transition to: #{desired_state}"
end
EM.tick_loop do
reload
current_state = state
if current_state.eql?(desired_state.to_s)
Logger.log.info "state changed from: #{current_state} => #{desired_state}"
EM.stop
else
Logger.log.info "waiting for state change: #{current_state} => #{desired_state}"
sleep(1)
end
end
end
end
end
end
end
end
Version data entries
4 entries across 4 versions & 1 rubygems