class Fog::AWS::Compute::SpotRequests
Public Class Methods
new(attributes)
click to toggle source
Calls superclass method
# File lib/fog/aws/models/compute/spot_requests.rb, line 11 def initialize(attributes) self.filters ||= {} super end
Public Instance Methods
all(filters = self.filters)
click to toggle source
# File lib/fog/aws/models/compute/spot_requests.rb, line 16 def all(filters = self.filters) unless filters.is_a?(Hash) Fog::Logger.deprecation("all with #{filters.class} param is deprecated, use all('spot-instance-request-id' => []) instead [light_black](#{caller.first})[/]") filters = {'spot-instance-request-id' => [*filters]} end self.filters = filters data = service.describe_spot_instance_requests(filters).body load( data['spotInstanceRequestSet'].map do |spot_instance_request| spot_instance_request['LaunchSpecification.Placement.AvailabilityZone'] = spot_instance_request['launchedAvailabilityZone'] spot_instance_request['launchSpecification'].each do |name,value| spot_instance_request['LaunchSpecification.' + name[0,1].upcase + name[1..-1]] = value end spot_instance_request.merge(:groups => spot_instance_request['LaunchSpecification.GroupSet']) spot_instance_request end.flatten ) end
bootstrap(new_attributes = {})
click to toggle source
# File lib/fog/aws/models/compute/spot_requests.rb, line 35 def bootstrap(new_attributes = {}) spot_request = service.spot_requests.new(new_attributes) unless new_attributes[:key_name] # first or create fog_#{credential} keypair name = Fog.respond_to?(:credential) && Fog.credential || :default unless spot_request.key_pair = service.key_pairs.get("fog_#{name}") spot_request.key_pair = service.key_pairs.create( :name => "fog_#{name}", :public_key => spot_request.public_key ) end end # make sure port 22 is open in the first security group security_group = service.security_groups.get(spot_request.groups.first) authorized = security_group.ip_permissions.find do |ip_permission| ip_permission['ipRanges'].first && ip_permission['ipRanges'].first['cidrIp'] == '0.0.0.0/0' && ip_permission['fromPort'] == 22 && ip_permission['ipProtocol'] == 'tcp' && ip_permission['toPort'] == 22 end unless authorized security_group.authorize_port_range(22..22) end spot_request.save Fog.wait_for { spot_request.reload.ready? rescue nil } server = service.servers.get(spot_request.instance_id) if spot_request.tags service.create_tags( spot_request.instance_id, spot_request.tags ) end server.wait_for { ready? } server.setup(:key_data => [spot_request.private_key]) server end
get(spot_request_id)
click to toggle source
# File lib/fog/aws/models/compute/spot_requests.rb, line 75 def get(spot_request_id) if spot_request_id self.class.new(:service => service).all('spot-instance-request-id' => spot_request_id).first end rescue Fog::Errors::NotFound nil end