Object
# File lib/openshift/application_container_proxy.rb, line 86 def self.blacklisted?(name) self.get_blacklisted.include?(name) end
# File lib/openshift/application_container_proxy.rb, line 106 def self.execute_parallel_jobs(handle) @proxy_provider.execute_parallel_jobs_impl(handle) end
Finds a server that matches the required criteria.
@param opts [Hash] Flexible array of optional parameters
node_profile [String] Gear size to filter disrict_uuid [String] Unique identifier for district least_preferred_servers [Array<String>] List of least preferred server identities restricted_servers [Array<String>] List of restricted server identities gear [Gear] Gear object
# File lib/openshift/application_container_proxy.rb, line 35 def self.find_available(opts=nil) opts ||= {} server_infos = @proxy_provider.find_all_available_impl(opts) server_id, district = select_best_fit_node(server_infos, opts[:gear]) raise OpenShift::NodeUnavailableException.new("No nodes available", 140) if server_id.nil? @proxy_provider.new(server_id, district) end
# File lib/openshift/application_container_proxy.rb, line 44 def self.find_one(node_profile=nil, platform='linux') server_id = @proxy_provider.find_one_impl(node_profile, platform) raise OpenShift::NodeUnavailableException.new("No nodes available", 140) if server_id.blank? @proxy_provider.new(server_id) end
# File lib/openshift/application_container_proxy.rb, line 98 def self.get_all_active_gears @proxy_provider.get_all_active_gears_impl end
# File lib/openshift/application_container_proxy.rb, line 94 def self.get_all_gears(opts = {}) @proxy_provider.get_all_gears_impl(opts) end
# File lib/openshift/application_container_proxy.rb, line 90 def self.get_all_gears_endpoints(opts = {}) @proxy_provider.get_all_gears_endpoints_impl(opts) end
# File lib/openshift/application_container_proxy.rb, line 102 def self.get_all_gears_sshkeys @proxy_provider.get_all_gears_sshkeys_impl end
# File lib/openshift/application_container_proxy.rb, line 78 def self.get_blacklisted @proxy_provider.get_blacklisted_in_impl end
# File lib/openshift/application_container_proxy.rb, line 82 def self.get_blacklisted_in_impl [] end
# File lib/openshift/application_container_proxy.rb, line 110 def self.get_details_for_all(name_list) @proxy_provider.get_details_for_all_impl(name_list) end
# File lib/openshift/application_container_proxy.rb, line 22 def self.instance(id) @proxy_provider.new(id) end
# File lib/openshift/application_container_proxy.rb, line 18 def self.node_selector_plugin=(node_selector_plugin_class) @node_selector = node_selector_plugin_class end
# File lib/openshift/application_container_proxy.rb, line 14 def self.provider=(provider_class) @proxy_provider = provider_class end
# File lib/openshift/application_container_proxy.rb, line 50 def self.select_best_fit_node(server_infos, gear) server_id = nil district = nil if @node_selector.nil? server_info = @proxy_provider.select_best_fit_node_impl(server_infos) server_id = server_info.name district = District.find_by(:_id => server_info.district_id) if server_info.district_id else if gear app_props = ApplicationProperties.new(gear.application) user_props = UserProperties.new(gear.application.domain.owner) current_gears = gear.application.gears.map {|g| GearProperties.new(g) unless g.server_identity.nil?} current_gears.delete_if {|g| g.nil?} comp_list = gear.component_instances.map {|ci| ComponentProperties.new(ci)} end # sending the request time to the plugin # since the request is processed inline currently, sending Time.now for now # later, if asynchronous request processing is performed, we will store the request time and pass it along request_time = Time.now node = @node_selector.select_best_fit_node_impl(server_infos, app_props, current_gears, comp_list, user_props, request_time) server_id = node.name district = District.find_by(:_id => node.district_id) if node.district_id end return server_id, district end
# File lib/openshift/application_container_proxy.rb, line 114 def self.set_district_uid_limits(uuid, first_uid, max_uid) @proxy_provider.set_district_uid_limits_impl(uuid, first_uid, max_uid) end
Generated with the Darkfish Rdoc Generator 2.