Contents

# -*- coding: utf-8 -*-

module Dcmgr::Tags
  include Dcmgr
  KEY_MAP={10=>:NetworkPool, 11=>:HostPool, 12=>:StoragePool}.freeze
  MODEL_MAP=KEY_MAP.invert.freeze

  def self.type_id(class_or_sym)
    k = case class_or_sym
    when String, Symbol
      class_or_sym.to_sym
    when Class
      class_or_sym.to_s.split('::').last.to_sym
    end

    MODEL_MAP[k] || raise("Unknown key to get type_id: #{class_or_sym}")
  end
  
  class NetworkPool < Models::Tag
    def accept_mapping?(to)
      to.is_a?(Dcmgr::Models::Network)
    end

    def pick()
      lst = mapped_uuids.map { |t|
        Dcmgr::Models::Network[t.uuid]
      }.sort_by{ |n|
        n.available_ip_nums
      }.reverse.first
    end
  end
  
  class HostPool < Models::Tag
    def accept_mapping?(to)
      to.is_a?(Dcmgr::Models::HostNode)
    end

    def pick(spec)
      mapped_uuids.map { |t|
        Dcmgr::Models::HostPool[t.uuid]
      }.find_all { |h|
        h.check_capacity(spec)
      }.sort_by { |h|
        h.instances.count
      }.reverse.first
    end    
  end
  
  class StoragePool < Models::Tag
    def accept_mapping?(to)
      to.is_a?(Dcmgr::Models::StorageNode)
    end
  end
end

Version data entries

2 entries across 2 versions & 2 rubygems

Version	Path
wakame-vdc-dcmgr-10.12.0	lib/dcmgr/tags.rb
wakame-vdc-agents-10.12.0	lib/dcmgr/tags.rb