mirror of
https://github.com/fog/fog-aws.git
synced 2022-11-09 13:50:52 -05:00
119 lines
5.2 KiB
Ruby
119 lines
5.2 KiB
Ruby
require 'fog/compute/models/server'
|
|
|
|
module Fog
|
|
module Compute
|
|
class AWS
|
|
class SpotRequest < Fog::Compute::Server
|
|
identity :id, :aliases => 'spotInstanceRequestId'
|
|
|
|
attribute :price, :aliases => 'spotPrice'
|
|
attribute :request_type, :aliases => 'type'
|
|
attribute :created_at, :aliases => 'createTime'
|
|
attribute :instance_count, :aliases => 'instanceCount'
|
|
attribute :instance_id, :aliases => 'instanceId'
|
|
attribute :state
|
|
|
|
attribute :valid_from, :aliases => 'validFrom'
|
|
attribute :valid_until, :aliases => 'validUntil'
|
|
attribute :launch_group, :aliases => 'launchGroup'
|
|
attribute :availability_zone_group, :aliases => 'availabilityZoneGroup'
|
|
attribute :product_description, :aliases => 'productDescription'
|
|
|
|
attribute :ebs_optimized, :aliases => 'LaunchSpecification.EbsOptimized'
|
|
attribute :groups, :aliases => 'LaunchSpecification.SecurityGroup'
|
|
attribute :key_name, :aliases => 'LaunchSpecification.KeyName'
|
|
attribute :availability_zone, :aliases => 'LaunchSpecification.Placement.AvailabilityZone'
|
|
attribute :flavor_id, :aliases => 'LaunchSpecification.InstanceType'
|
|
attribute :image_id, :aliases => 'LaunchSpecification.ImageId'
|
|
attribute :monitoring, :aliases => 'LaunchSpecification.Monitoring'
|
|
attribute :block_device_mapping, :aliases => 'LaunchSpecification.BlockDeviceMapping'
|
|
attribute :subnet_id, :aliases => 'LaunchSpecification.SubnetId'
|
|
attribute :iam_instance_profile, :aliases => 'LaunchSpecification.IamInstanceProfile'
|
|
|
|
attribute :tags, :aliases => 'tagSet'
|
|
attribute :fault, :squash => 'message'
|
|
attribute :user_data
|
|
|
|
attr_writer :iam_instance_profile_name, :iam_instance_profile_arn
|
|
|
|
def initialize(attributes={})
|
|
self.groups ||= ["default"]
|
|
self.flavor_id ||= 't1.micro'
|
|
self.image_id ||= begin
|
|
self.username ||= 'ubuntu'
|
|
|
|
# Old 'connection' is renamed as service and should be used instead
|
|
prepare_service_value(attributes)
|
|
|
|
case @service.instance_variable_get(:@region) # Ubuntu 10.04 LTS 64bit (EBS)
|
|
when 'ap-northeast-1'
|
|
'ami-5e0fa45f'
|
|
when 'ap-southeast-1'
|
|
'ami-f092eca2'
|
|
when 'eu-west-1'
|
|
'ami-3d1f2b49'
|
|
when 'us-east-1'
|
|
'ami-3202f25b'
|
|
when 'us-west-1'
|
|
'ami-f5bfefb0'
|
|
end
|
|
end
|
|
super
|
|
end
|
|
|
|
def destroy
|
|
requires :id
|
|
|
|
service.cancel_spot_instance_requests(id)
|
|
true
|
|
end
|
|
|
|
def key_pair
|
|
requires :key_name
|
|
|
|
service.key_pairs.all(key_name).first
|
|
end
|
|
|
|
def key_pair=(new_keypair)
|
|
self.key_name = new_keypair && new_keypair.name
|
|
end
|
|
|
|
def ready?
|
|
state == 'active'
|
|
end
|
|
|
|
def save
|
|
requires :image_id, :flavor_id, :price
|
|
|
|
options = {
|
|
'AvailabilityZoneGroup' => availability_zone_group,
|
|
'InstanceCount' => instance_count,
|
|
'LaunchGroup' => launch_group,
|
|
'LaunchSpecification.BlockDeviceMapping' => block_device_mapping,
|
|
'LaunchSpecification.KeyName' => key_name,
|
|
'LaunchSpecification.Monitoring.Enabled' => monitoring,
|
|
'LaunchSpecification.Placement.AvailabilityZone' => availability_zone,
|
|
'LaunchSpecification.SecurityGroupId' => groups,
|
|
'LaunchSpecification.EbsOptimized' => ebs_optimized,
|
|
'LaunchSpecification.UserData' => user_data,
|
|
'LaunchSpecification.SubnetId' => subnet_id,
|
|
'LaunchSpecification.IamInstanceProfile.Arn' => @iam_instance_profile_arn,
|
|
'LaunchSpecification.IamInstanceProfile.Name' => @iam_instance_profile_name,
|
|
'Type' => request_type,
|
|
'ValidFrom' => valid_from,
|
|
'ValidUntil' => valid_until }
|
|
options.delete_if {|key, value| value.nil?}
|
|
|
|
data = service.request_spot_instances(image_id, flavor_id, price, options).body
|
|
spot_instance_request = data['spotInstanceRequestSet'].first
|
|
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.merge(options)
|
|
merge_attributes( spot_instance_request )
|
|
end
|
|
end
|
|
end
|
|
end
|
|
end
|