Class: Proxmox::Hosted

Inherits:

Base

• Object
• Base
• Proxmox::Hosted

Defined in:

lib/pve/proxmox.rb

Direct Known Subclasses

LXC, Qemu

Instance Attribute Summary

Attributes inherited from Base

#sid

Instance Method Summary

• #===(t) ⇒ Object
• #cnfset(**cnf) ⇒ Object
• #config ⇒ Object
• #current_status ⇒ Object
• #destroy ⇒ Object
• #migrate(node) ⇒ Object
• #refresh! ⇒ Object
• #resize(disk, size) ⇒ Object
• #running? ⇒ Boolean
• #start ⇒ Object
• #stop ⇒ Object
• #stopped? ⇒ Boolean
• #wait(forstatus, timeout: nil, secs: nil, lock: nil, &exe) ⇒ Object

Methods inherited from Base

__new__, fetch, #method_missing, #respond_to?

Methods included from RestConnection

#bench, #rest_del, #rest_get, #rest_post, #rest_put

Dynamic Method Handling

This class handles dynamic methods through the method_missing method in the class Proxmox::Base

Instance Method Details

#===(t) ⇒ Object

# File 'lib/pve/proxmox.rb', line 294

def === t
  @name =~ t or @vmid.to_s =~ t or @sid =~ t
end

#cnfset(**cnf) ⇒ Object

# File 'lib/pve/proxmox.rb', line 373

def cnfset **cnf
  r = {delete: []}
  cnf.each do |k,v|
    case v
    when true then r[k] = 1
    when false then r[k] = 0
    when nil then r[:delete].push k
    else r[k] = v
    end
  end
  r.delete :delete  if r[:delete].empty?
  rest_put "#{@rest_prefix}/config", r
end

#config ⇒ Object

# File 'lib/pve/proxmox.rb', line 345

def config
  cnf = rest_get "#{@rest_prefix}/config"
  cnf[:network] =
    cnf.
      keys.
      map( &:to_s).
      grep( /\Anet\d+\z/).
      map do |k|
        nc = {card: k}
        cnf.delete( k.to_sym).
          split( ',').
          each do |f|
            k, v = f.split( '=', 2)
            nc[k.to_sym] = v
          end
        nc[:ip] &&= IPAddress::IPv4.new nc[:ip]
        nc[:gw] &&= IPAddress::IPv4.new nc[:gw]
        nc[:mtu] &&= nc[:mtu].to_i
        nc[:tag] &&= nc[:tag].to_i
        nc[:firewall] &&= 1 == nc[:firewall].to_i
        nc
      end
  cnf[:unprivileged] &&= 1 == cnf[:unprivileged]
  cnf[:memory] &&= cnf[:memory].to_i
  cnf[:cores] &&= cnf[:cores].to_i
  cnf
end

#current_status ⇒ Object

# File 'lib/pve/proxmox.rb', line 319

def current_status
  rest_get "#{@rest_prefix}/status/current"
end

#destroy ⇒ Object

# File 'lib/pve/proxmox.rb', line 315

def destroy
  Task.send :__new__, node: @node, host: self, upid: rest_del( "#{@rest_prefix}")
end

#migrate(node) ⇒ Object

# File 'lib/pve/proxmox.rb', line 298

def migrate node
  node =
    case node
    when Node then node
    else Node.find!( node.to_s)
    end
  Task.send :__new__, node: @node, host: self, upid: rest_post( "#{@rest_prefix}/migrate", target: node.node)
end

#refresh! ⇒ Object

# File 'lib/pve/proxmox.rb', line 290

def refresh!
  __update__ rest_get( "#{@rest_prefix}/status/current").merge( node: @node, t: @t)
end

#resize(disk, size) ⇒ Object

# File 'lib/pve/proxmox.rb', line 387

def resize disk, size
  upid = rest_put "#{@rest_prefix}/resize", disk: disk, size: size
  Task.send :__new__, node: @node, host: self, upid: upid
end

#running? ⇒ Boolean

Returns:

• (Boolean)

# File 'lib/pve/proxmox.rb', line 323

def running?
  current_status[:status] == 'running'
end

#start ⇒ Object

# File 'lib/pve/proxmox.rb', line 307

def start
  Task.send :__new__, node: @node, host: self, upid: rest_post( "#{@rest_prefix}/status/start")
end

#stop ⇒ Object

# File 'lib/pve/proxmox.rb', line 311

def stop
  Task.send :__new__, node: @node, host: self, upid: rest_post( "#{@rest_prefix}/status/stop")
end

#stopped? ⇒ Boolean

Returns:

• (Boolean)

# File 'lib/pve/proxmox.rb', line 327

def stopped?
  current_status[:status] == 'stopped'
end

#wait(forstatus, timeout: nil, secs: nil, lock: nil, &exe) ⇒ Object

# File 'lib/pve/proxmox.rb', line 331

def wait forstatus, timeout: nil, secs: nil, lock: nil, &exe
  forstatus = forstatus.to_s
  secs ||= 0.2
  b = Time.now + timeout.to_i + secs
  loop do
    d = current_status
    return true  if d[:status] == forstatus and (not lock or lock == d[:lock])
    exe.call d[:status], d[:lock]  if exe
    return false  if timeout and b <= Time.now
    sleep secs
  end
  nil
end