class NonstandardPooler
Public Class Methods
delete(verbose, url, hosts, token, _user)
click to toggle source
# File lib/vmfloaty/nonstandard_pooler.rb, line 81 def self.delete(verbose, url, hosts, token, _user) raise TokenError, 'Token provided was nil; Request cannot be made to delete VM' if token.nil? conn = Http.get_conn(verbose, url) conn.headers['X-AUTH-TOKEN'] = token if token response_body = {} hosts = hosts.split(',') unless hosts.is_a? Array hosts.each do |host| response = conn.delete "host/#{host}" res_body = JSON.parse(response.body) response_body[host] = res_body end response_body end
disk(_verbose, _url, _hostname, _token, _disk)
click to toggle source
# File lib/vmfloaty/nonstandard_pooler.rb, line 69 def self.disk(_verbose, _url, _hostname, _token, _disk) raise ModifyError, 'Configured service type does not support modification of disk space' end
list(verbose, url, os_filter = nil)
click to toggle source
# File lib/vmfloaty/nonstandard_pooler.rb, line 9 def self.list(verbose, url, os_filter = nil) conn = Http.get_conn(verbose, url) response = conn.get 'status' response_body = JSON.parse(response.body) os_list = response_body.keys.sort os_list.delete 'ok' os_filter ? os_list.select { |i| i[/#{os_filter}/] } : os_list end
list_active(verbose, url, token, _user)
click to toggle source
# File lib/vmfloaty/nonstandard_pooler.rb, line 20 def self.list_active(verbose, url, token, _user) status = Auth.token_status(verbose, url, token) status['reserved_hosts'] || [] end
modify(verbose, url, hostname, token, modify_hash)
click to toggle source
# File lib/vmfloaty/nonstandard_pooler.rb, line 45 def self.modify(verbose, url, hostname, token, modify_hash) raise TokenError, 'Token provided was nil; Request cannot be made to modify VM' if token.nil? modify_hash.each do |key, _value| raise ModifyError, "Configured service type does not support modification of #{key}" unless %i[reason reserved_for_reason].include? key end if modify_hash[:reason] # "reason" is easier to type than "reserved_for_reason", but nspooler needs the latter modify_hash[:reserved_for_reason] = modify_hash.delete :reason end conn = Http.get_conn(verbose, url) conn.headers['X-AUTH-TOKEN'] = token response = conn.put do |req| req.url "host/#{hostname}" req.body = modify_hash.to_json end response.body.empty? ? {} : JSON.parse(response.body) end
query(verbose, url, hostname)
click to toggle source
# File lib/vmfloaty/nonstandard_pooler.rb, line 114 def self.query(verbose, url, hostname) conn = Http.get_conn(verbose, url) response = conn.get "host/#{hostname}" JSON.parse(response.body) end
retrieve(verbose, os_type, token, url, _user, _options, _ondemand = nil, _continue = nil)
click to toggle source
# File lib/vmfloaty/nonstandard_pooler.rb, line 25 def self.retrieve(verbose, os_type, token, url, _user, _options, _ondemand = nil, _continue = nil) conn = Http.get_conn(verbose, url) conn.headers['X-AUTH-TOKEN'] = token if token os_string = os_type.map { |os, num| Array(os) * num }.flatten.join('+') raise MissingParamError, 'No operating systems provided to obtain.' if os_string.empty? response = conn.post "host/#{os_string}" res_body = JSON.parse(response.body) if res_body['ok'] res_body elsif response.status == 401 raise AuthError, "HTTP #{response.status}: The token provided could not authenticate to the pooler.\n#{res_body}" else raise "HTTP #{response.status}: Failed to obtain VMs from the pooler at #{url}/host/#{os_string}. #{res_body}" end end
revert(_verbose, _url, _hostname, _token, _snapshot_sha)
click to toggle source
# File lib/vmfloaty/nonstandard_pooler.rb, line 77 def self.revert(_verbose, _url, _hostname, _token, _snapshot_sha) raise ModifyError, 'Configured service type does not support snapshots' end
snapshot(_verbose, _url, _hostname, _token)
click to toggle source
# File lib/vmfloaty/nonstandard_pooler.rb, line 73 def self.snapshot(_verbose, _url, _hostname, _token) raise ModifyError, 'Configured service type does not support snapshots' end
status(verbose, url)
click to toggle source
# File lib/vmfloaty/nonstandard_pooler.rb, line 100 def self.status(verbose, url) conn = Http.get_conn(verbose, url) response = conn.get '/status' JSON.parse(response.body) end
summary(verbose, url)
click to toggle source
# File lib/vmfloaty/nonstandard_pooler.rb, line 107 def self.summary(verbose, url) conn = Http.get_conn(verbose, url) response = conn.get '/summary' JSON.parse(response.body) end