mirror of
https://github.com/fog/fog.git
synced 2022-11-09 13:51:43 -05:00
40c0cd7122
In many places we were checking for identity which was the shorthand for checking if the resource had been saved by the service. The #persisted? method was added to show a clearer intent and also offer minimal ActiveModel interface
135 lines
3.3 KiB
Ruby
135 lines
3.3 KiB
Ruby
require 'fog/compute/models/server'
|
|
|
|
module Fog
|
|
module Compute
|
|
class Ovirt
|
|
|
|
class Server < Fog::Compute::Server
|
|
|
|
# This will be the instance uuid which is globally unique across
|
|
# a oVirt deployment.
|
|
identity :id
|
|
|
|
attribute :name
|
|
attribute :description
|
|
attribute :profile
|
|
attribute :display
|
|
attribute :storage, :aliases => 'disk_size'
|
|
attribute :creation_time
|
|
attribute :os
|
|
attribute :ip
|
|
attribute :status
|
|
attribute :cores, :aliases => 'cpus'
|
|
attribute :memory
|
|
attribute :host
|
|
attribute :cluster
|
|
attribute :template
|
|
attribute :interfaces
|
|
attribute :volumes
|
|
attribute :raw
|
|
|
|
def ready?
|
|
!(status =~ /down/i)
|
|
end
|
|
|
|
def locked?
|
|
!!(status =~ /locked/i)
|
|
end
|
|
|
|
def stopped?
|
|
!!(status =~ /down/i)
|
|
end
|
|
|
|
def mac
|
|
interfaces.first.mac unless interfaces.empty?
|
|
end
|
|
|
|
def interfaces
|
|
attributes[:interfaces] ||= id.nil? ? [] : Fog::Compute::Ovirt::Interfaces.new(
|
|
:connection => connection,
|
|
:vm => self
|
|
)
|
|
end
|
|
|
|
def add_interface attrs
|
|
wait_for { stopped? } if attrs[:blocking]
|
|
connection.add_interface(id, attrs)
|
|
end
|
|
|
|
def update_interface attrs
|
|
wait_for { stopped? } if attrs[:blocking]
|
|
connection.update_interface(id, attrs)
|
|
end
|
|
|
|
def destroy_interface attrs
|
|
wait_for { stopped? } if attrs[:blocking]
|
|
connection.destroy_interface(id, attrs)
|
|
end
|
|
|
|
def volumes
|
|
attributes[:volumes] ||= id.nil? ? [] : Fog::Compute::Ovirt::Volumes.new(
|
|
:connection => connection,
|
|
:vm => self
|
|
)
|
|
end
|
|
|
|
def add_volume attrs
|
|
wait_for { stopped? } if attrs[:blocking]
|
|
connection.add_volume(id, attrs)
|
|
end
|
|
|
|
def destroy_volume attrs
|
|
wait_for { stopped? } if attrs[:blocking]
|
|
connection.destroy_volume(id, attrs)
|
|
end
|
|
|
|
def start(options = {})
|
|
wait_for { stopped? } if options[:blocking]
|
|
connection.vm_action(:id =>id, :action => :start)
|
|
reload
|
|
end
|
|
|
|
def stop(options = {})
|
|
connection.vm_action(:id =>id, :action => :stop)
|
|
reload
|
|
end
|
|
|
|
def reboot(options = {})
|
|
stop unless stopped?
|
|
start options.merge(:blocking => true)
|
|
end
|
|
|
|
def suspend(options = {})
|
|
connection.vm_action(:id =>id, :action => :suspend)
|
|
reload
|
|
end
|
|
|
|
def destroy(options = {})
|
|
(stop unless stopped?) rescue nil #ignore failure, destroy the machine anyway.
|
|
wait_for { stopped? }
|
|
connection.destroy_vm(:id => id)
|
|
end
|
|
|
|
def ticket(options = {})
|
|
raise "Can not set console ticket, Server is not ready. Server status: #{status}" unless ready?
|
|
connection.vm_ticket(id, options)
|
|
end
|
|
|
|
def save
|
|
if persisted?
|
|
connection.update_vm(attributes)
|
|
else
|
|
self.id = connection.create_vm(attributes).id
|
|
end
|
|
reload
|
|
end
|
|
|
|
def to_s
|
|
name
|
|
end
|
|
|
|
end
|
|
|
|
end
|
|
end
|
|
end
|