Sha256: 91241ef547d85729a3856bbf958212274bec546678a2f40749985671044ffcfb
Contents?: true
Size: 1.99 KB
Versions: 17
Compression:
Stored size: 1.99 KB
Contents
require 'fog'
require 'active_support/core_ext/hash/slice'
require 'guignol'
require 'guignol/models/base'
module Guignol::Models
class Volume < Base
class Error < Exception; end
def availability_zone
subject && subject.availability_zone
end
def create
log "volume already exists" and return self if exist?
log "creating volume"
create_options = Guignol::DefaultVolumeOptions.merge options.slice(:availability_zone, :size, :snapshot, :delete_on_termination)
set_subject connection.volumes.create(create_options)
update_tags
wait_for_state 'available'
return self
rescue Exception => e
log "error while creating (#{e.class.name})"
destroy
raise
end
def destroy
return self unless exist?
log "destroying volume"
subject.destroy
wait_for_state 'deleted'
# FIXME: remove tags here
set_subject nil
return self
end
def attach(server_id)
exist? or create
subject.reload
if subject.server_id == server_id
if subject.device == options[:dev]
log "volume already attached"
return
else
log "error: volume attached to device #{subject.device} instead of options[:dev]"
raise Error.new('already attached')
end
end
response = connection.attach_volume(server_id, subject.id, options[:dev])
response.status == 200 or raise Error.new('failed to attach volume')
update_tags
return self
end
private
def find_subject
connection.volumes.
select { |s| %w(in-use available).include?(s.state) }.
find { |s| s.tags['UUID'] == uuid }
end
def update_tags
log "updating tags"
tags = { 'Name' => name, 'UUID' => uuid }
response = connection.create_tags(subject.id, tags)
unless response.status == 200
log "updating tags failed"
destroy and raise Error.new('updating tags failed')
end
end
end
end
Version data entries
17 entries across 17 versions & 1 rubygems