Class: OneGroupHelper

Inherits:

OpenNebulaHelper::OneHelper

• Object
• OpenNebulaHelper::OneHelper
• OneGroupHelper

Defined in:

lib/one_helper/onegroup_helper.rb

Overview

CLI helper for onegroup command

Instance Attribute Summary

Attributes inherited from OpenNebulaHelper::OneHelper

#client

Class Method Summary

• .conf_file ⇒ Object
• .rname ⇒ Object

Instance Method Summary

• #create_complete_resource(group_hash) ⇒ Object
• #create_resource(options, &block) ⇒ Object
• #format_pool(_options) ⇒ Object
• #parse_template(tmpl_str) ⇒ Hash, Zona::Error

  Parses a OpenNebula template string and turns it into a Hash.

Methods inherited from OpenNebulaHelper::OneHelper

#backup_mode_valid?, #check_orphan, client, #filterflag_to_i, filterflag_to_i_desc, get_client, get_password, #group_name, #initialize, list_layout_help, #list_pool, #list_pool_format, #list_pool_table, #list_pool_top, #list_pool_xml, #list_to_id, list_to_id_desc, name_to_id, #perform_action, #perform_actions, #print_page, #retrieve_resource, #set_client, set_endpoint, set_password, set_user, #show_resource, #start_pager, #stop_pager, table_conf, template_input_help, #to_id, to_id_desc, #user_name

Constructor Details

This class inherits a constructor from OpenNebulaHelper::OneHelper

Class Method Details

.conf_file ⇒ Object

# File 'lib/one_helper/onegroup_helper.rb', line 29

def self.conf_file
    'onegroup.yaml'
end

.rname ⇒ Object

# File 'lib/one_helper/onegroup_helper.rb', line 25

def self.rname
    'GROUP'
end

Instance Method Details

#create_complete_resource(group_hash) ⇒ Object

# File 'lib/one_helper/onegroup_helper.rb', line 55

def create_complete_resource(group_hash)
    group = factory
    rc = group.create(group_hash)

    if OpenNebula.is_error?(rc)
        return -1, rc.message
    end

    puts "ID: #{group.id}"
    return 0
end

#create_resource(options, &block) ⇒ Object

# File 'lib/one_helper/onegroup_helper.rb', line 33

def create_resource(options, &block)
    group = factory

    rc = block.call(group)

    if OpenNebula.is_error?(rc)
        return -1, rc.message
    else
        puts "ID: #{group.id}"
    end

    puts "Creating default ACL rules: #{GROUP_DEFAULT_ACLS}" if options[:verbose]

    exit_code, _msg = group.create_default_acls

    if OpenNebula.is_error?(exit_code)
        return -1, exit_code.message
    end

    exit_code.to_i
end

#format_pool(_options) ⇒ Object

# File 'lib/one_helper/onegroup_helper.rb', line 67

def format_pool(_options)
    config_file = self.class.table_conf

    # rubocop:disable Style/FormatStringToken
    CLIHelper::ShowTable.new(config_file, self) do
        pool_default_quotas = lambda do |path|
            limit = @data.dsearch('/GROUP_POOL/DEFAULT_GROUP_QUOTAS/'+path)
            limit = OneQuotaHelper::LIMIT_UNLIMITED if limit.nil? || limit.empty?
            limit
        end

        quotas_proc = lambda do
            if !defined?(@quotas)
                quotas = @data.dsearch('GROUP_POOL/QUOTAS')
                @quotas = {}

                if !quotas.nil?
                    quotas = [quotas].flatten

                    quotas.each do |q|
                        # Fix rare bug, when there are multiple VM_QUOTA values
                        vm_quota = q['VM_QUOTA']
                        if vm_quota.is_a?(Array)
                            q['VM_QUOTA'] = vm_quota.max_by {|h| h.size }
                        end

                        @quotas[q['ID']] = q
                    end
                end
            end
            @quotas
        end

        column :ID, 'ONE identifier for the Group', :size=>4 do |d|
            d['ID']
        end

        column :NAME, 'Name of the Group', :left, :size=>29 do |d|
            d['NAME']
        end

        column :USERS, 'Number of Users in this group', :size=>5 do |d|
            ids = d['USERS']['ID']

            case ids
            when String
                '1'
            when Array
                ids.size
            else
                '0'
            end
        end

        column :VMS, 'Number of VMS', :size=>9 do |d|
            begin
                q = quotas_proc.call[d['ID']]['VM_QUOTA']['VM']

                if q.nil? && d['ID'].to_i != 0
                    q = OneQuotaHelper::DEFAULT_VM_QUOTA
                end

                # In case of multiple quotas, use the global quota or the first
                if q.is_a?(Array)
                    global_h = q.find {|h| h['CLUSTER_IDS'].nil? || h['CLUSTER_IDS'].empty? }
                    q = global_h || q[0]
                end

                limit = q['VMS']
                limit = pool_default_quotas.call('VM_QUOTA/VM/VMS') if limit == OneQuotaHelper::LIMIT_DEFAULT

                if limit == OneQuotaHelper::LIMIT_UNLIMITED
                    format('%3d /   -', q['VMS_USED'])
                else
                    format('%3d / %3d', q['VMS_USED'], limit)
                end
            rescue NoMethodError
                '-'
            end
        end

        column :MEMORY, 'Total memory allocated to user VMs', :size=>15 do |d|
            begin
                q = quotas_proc.call[d['ID']]['VM_QUOTA']['VM']

                if q.nil? && d['ID'].to_i != 0
                    q = OneQuotaHelper::DEFAULT_VM_QUOTA
                end

                # In case of multiple quotas, use the global quota or the first
                if q.is_a?(Array)
                    global_h = q.find {|h| h['CLUSTER_IDS'].nil? || h['CLUSTER_IDS'].empty? }
                    q = global_h || q[0]
                end

                limit = q['MEMORY']
                limit = pool_default_quotas.call('VM_QUOTA/VM/MEMORY') if limit == OneQuotaHelper::LIMIT_DEFAULT

                if limit == OneQuotaHelper::LIMIT_UNLIMITED
                    format('%6s /      -',
                           OpenNebulaHelper.unit_to_str(q['MEMORY_USED'].to_i, {}, 'M'))
                else
                    format('%6s / %6s',
                           OpenNebulaHelper.unit_to_str(q['MEMORY_USED'].to_i, {}, 'M'),
                           OpenNebulaHelper.unit_to_str(limit.to_i, {}, 'M'))
                end
            rescue NoMethodError
                '-'
            end
        end

        column :CPU, 'Total CPU allocated to user VMs', :size=>11 do |d|
            begin
                q = quotas_proc.call[d['ID']]['VM_QUOTA']['VM']

                if q.nil? && d['ID'].to_i != 0
                    q = OneQuotaHelper::DEFAULT_VM_QUOTA
                end

                # In case of multiple quotas, use the global quota or the first
                if q.is_a?(Array)
                    global_h = q.find {|h| h['CLUSTER_IDS'].nil? || h['CLUSTER_IDS'].empty? }
                    q = global_h || q[0]
                end

                limit = q['CPU']
                limit = pool_default_quotas.call('VM_QUOTA/VM/CPU') if limit == OneQuotaHelper::LIMIT_DEFAULT

                if limit == OneQuotaHelper::LIMIT_UNLIMITED
                    format('%3.1f /    -', q['CPU_USED'])
                else
                    format('%3.1f / %3.1f', q['CPU_USED'], limit)
                end
            rescue NoMethodError
                '-'
            end
        end

        column :PCI, 'Total PCIs allocated to user VMs', :size=>9 do |d|
            begin
                q = quotas_proc.call[d['ID']]['VM_QUOTA']['VM']

                if q.nil? && d['ID'].to_i != 0
                    q = OneQuotaHelper::DEFAULT_VM_QUOTA
                end

                # In case of multiple quotas, use the global quota or the first
                if q.is_a?(Array)
                    global_q = q.find {|h| h['CLUSTER_IDS'].nil? || h['CLUSTER_IDS'].empty? }
                    q = global_q || q[0]
                end

                limit = q['PCI_DEV']
                limit = pool_default_quotas.call('VM_QUOTA/VM/PCI_DEV') if limit == OneQuotaHelper::LIMIT_DEFAULT

                if limit == OneQuotaHelper::LIMIT_UNLIMITED
                    format('%3s /   -', q['PCI_DEV_USED'])
                else
                    format('%3s / %3s', q['PCI_DEV_USED'], limit)
                end
            rescue NoMethodError
                '-'
            end
        end

        default :ID, :NAME, :USERS, :VMS, :MEMORY, :CPU, :PCI
    end
    # rubocop:enable Style/FormatStringToken
end

#parse_template(tmpl_str) ⇒ Hash, Zona::Error

Parses a OpenNebula template string and turns it into a Hash

Parameters:

• tmpl_str (String) —

  template

Returns:

• (Hash, Zona::Error) —

  Hash or Error

# File 'lib/one_helper/onegroup_helper.rb', line 240

def parse_template(tmpl_str)
    name_reg     =/[\w\d_-]+/
    variable_reg =/\s*(#{name_reg})\s*=\s*/
    single_variable_reg =/^#{variable_reg}([^\[]+?)(#.*)?$/

    tmpl         = {}
    tmpl['user'] = {}

    tmpl_str.scan(single_variable_reg) do |m|
        key   = m[0].strip.downcase
        value = m[1].strip.gsub('"', '')
        case key
        when 'admin_user_name'
            tmpl['user']['name']=value
        when 'admin_user_password'
            tmpl['user']['password']=value
        when 'admin_user_auth_driver'
            tmpl['user']['auth_driver']=value
        else
            tmpl[key] = value
        end
    end

    return tmpl
end