Class: OsCtl::Cli::Group

Inherits:

Command

• Object
• Lib::Cli::Command
• Command
• OsCtl::Cli::Group

Includes:

Assets, Attributes, CGroupParams, Devices

Defined in:

lib/osctl/cli/group.rb

Constant Summary

FIELDS =

%i[
  pool
  name
  path
  full_path
  cpu_limit
  memory_limit
  swap_limit
] + CGroupParams::CGPARAM_STATS

FILTERS =

%i[
  pool
].freeze

DEFAULT_FIELDS =

%i[
  pool
  name
  memory
  cpu_us
].freeze

Constants included from Devices

Devices::DEVICES_FIELDS

Constants included from CGroupParams

CGroupParams::CGPARAM_DEFAULT_FIELDS, CGroupParams::CGPARAM_FIELDS, CGroupParams::CGPARAM_FILTERS, CGroupParams::CGPARAM_STATS

Instance Method Summary

• #assets ⇒ Object
• #cgparam_apply ⇒ Object
• #cgparam_list ⇒ Object
• #cgparam_replace ⇒ Object
• #cgparam_set ⇒ Object
• #cgparam_unset ⇒ Object
• #create ⇒ Object
• #delete ⇒ Object
• #device_add ⇒ Object
• #device_chmod ⇒ Object
• #device_delete ⇒ Object
• #device_inherit ⇒ Object
• #device_list ⇒ Object
• #device_promote ⇒ Object
• #device_replace ⇒ Object
• #device_set_inherit ⇒ Object
• #device_unset_inherit ⇒ Object
• #list ⇒ Object
• #set_attr ⇒ Object
• #set_cpu_limit ⇒ Object
• #set_memory_limit ⇒ Object
• #show ⇒ Object
• #tree ⇒ Object
• #unset_attr ⇒ Object
• #unset_cpu_limit ⇒ Object
• #unset_memory_limit ⇒ Object

Methods included from Attributes

#do_set_attr, #do_unset_attr

Methods included from Assets

#print_assets

Methods included from Devices

#do_device_add, #do_device_chmod, #do_device_delete, #do_device_inherit, #do_device_list, #do_device_promote, #do_device_replace, #do_device_set_inherit, #do_device_unset_inherit

Methods included from CGroupParams

#cg_add_raw_cgroup_params, #cg_add_stats, #cg_init_subsystems, #cg_list_raw_cgroup_params, #do_cgparam_apply, #do_cgparam_list, #do_cgparam_replace, #do_cgparam_set, #do_cgparam_unset, #do_set_cpu_limit, #do_set_memory, #do_unset_cpu_limit, #do_unset_memory, #parse_cgparams, #parse_subsystem

Methods inherited from Command

#cli_opt, #format_output, #osctld_call, #osctld_fmt, #osctld_open, #osctld_resp, run

Instance Method Details

#assets ⇒ Object

# File 'lib/osctl/cli/group.rb', line 251

def assets
  require_args!('name')
  print_assets(:group_assets, name: args[0], pool: gopts[:pool])
end

#cgparam_apply ⇒ Object

# File 'lib/osctl/cli/group.rb', line 271

def cgparam_apply
  require_args!('name')
  do_cgparam_apply(:group_cgparam_apply, name: args[0], pool: gopts[:pool])
end

#cgparam_list ⇒ Object

# File 'lib/osctl/cli/group.rb', line 256

def cgparam_list
  require_args!('name', strict: false)
  do_cgparam_list(:group_cgparam_list, name: args[0], pool: gopts[:pool])
end

#cgparam_replace ⇒ Object

# File 'lib/osctl/cli/group.rb', line 276

def cgparam_replace
  require_args!('name')
  do_cgparam_replace(:group_cgparam_replace, name: args[0], pool: gopts[:pool])
end

#cgparam_set ⇒ Object

# File 'lib/osctl/cli/group.rb', line 261

def cgparam_set
  require_args!('name', 'parameter', 'value', strict: false)
  do_cgparam_set(:group_cgparam_set, name: args[0], pool: gopts[:pool])
end

#cgparam_unset ⇒ Object

# File 'lib/osctl/cli/group.rb', line 266

def cgparam_unset
  require_args!('name', 'parameter')
  do_cgparam_unset(:group_cgparam_unset, name: args[0], pool: gopts[:pool])
end

#create ⇒ Object

# File 'lib/osctl/cli/group.rb', line 181

def create
  require_args!('name')

  cmd_opts = {
    name: args[0],
    pool: opts[:pool] || gopts[:pool],
    parents: opts[:parents],
    cgparams: parse_cgparams
  }

  osctld_fmt(:group_create, cmd_opts:)
end

#delete ⇒ Object

# File 'lib/osctl/cli/group.rb', line 194

def delete
  require_args!('name')
  osctld_fmt(:group_delete, cmd_opts: { name: args[0], pool: gopts[:pool] })
end

#device_add ⇒ Object

# File 'lib/osctl/cli/group.rb', line 286

def device_add
  require_args!('name', 'type', 'major', 'minor', 'mode', optional: %w[device])
  do_device_add(:group_device_add, name: args[0], pool: gopts[:pool])
end

#device_chmod ⇒ Object

# File 'lib/osctl/cli/group.rb', line 296

def device_chmod
  require_args!('name', 'type', 'major', 'minor', 'mode')
  do_device_chmod(:group_device_chmod, name: args[0], pool: gopts[:pool])
end

#device_delete ⇒ Object

# File 'lib/osctl/cli/group.rb', line 291

def device_delete
  require_args!('name', 'type', 'major', 'minor')
  do_device_delete(:group_device_delete, name: args[0], pool: gopts[:pool])
end

#device_inherit ⇒ Object

# File 'lib/osctl/cli/group.rb', line 306

def device_inherit
  require_args!('name', 'type', 'major', 'minor')
  do_device_inherit(:group_device_inherit, name: args[0], pool: gopts[:pool])
end

#device_list ⇒ Object

# File 'lib/osctl/cli/group.rb', line 281

def device_list
  require_args!('name')
  do_device_list(:group_device_list, name: args[0], pool: gopts[:pool])
end

#device_promote ⇒ Object

# File 'lib/osctl/cli/group.rb', line 301

def device_promote
  require_args!('name', 'type', 'major', 'minor')
  do_device_chmod(:group_device_promote, name: args[0], pool: gopts[:pool])
end

#device_replace ⇒ Object

# File 'lib/osctl/cli/group.rb', line 321

def device_replace
  require_args!('name')
  do_device_replace(:group_device_replace, name: args[0], pool: gopts[:pool])
end

#device_set_inherit ⇒ Object

# File 'lib/osctl/cli/group.rb', line 311

def device_set_inherit
  require_args!('name', 'type', 'major', 'minor')
  do_device_set_inherit(:group_device_set_inherit, name: args[0], pool: gopts[:pool])
end

#device_unset_inherit ⇒ Object

# File 'lib/osctl/cli/group.rb', line 316

def device_unset_inherit
  require_args!('name', 'type', 'major', 'minor')
  do_device_unset_inherit(:group_device_unset_inherit, name: args[0], pool: gopts[:pool])
end

#list ⇒ Object

# File 'lib/osctl/cli/group.rb', line 34

def list
  c = osctld_open
  cg_init_subsystems(c)

  cgparams = cg_list_raw_cgroup_params

  param_selector = OsCtl::Lib::Cli::ParameterSelector.new(
    all_params: FIELDS + cgparams,
    default_params: DEFAULT_FIELDS
  )

  if opts[:list]
    puts param_selector
    return
  end

  cmd_opts = {}
  fmt_opts = {
    layout: :columns,
    sort: opts[:sort] && param_selector.parse_option(opts[:sort]),
    opts: {
      memory_limit: {
        align: 'right',
        display: proc do |v|
          if v.nil? || gopts[:parsable] || gopts[:json]
            v
          else
            humanize_data(v)
          end
        end
      },
      swap_limit: {
        align: 'right',
        display: proc do |v|
          if v.nil? || gopts[:parsable] || gopts[:json]
            v
          else
            humanize_data(v)
          end
        end
      }
    }
  }

  cmd_opts[:names] = args if args.count > 0

  FILTERS.each do |v|
    [gopts, opts].each do |options|
      next unless options[v]

      cmd_opts[v] = options[v].split(',')
    end
  end

  fmt_opts[:header] = false if opts['hide-header']

  cols = param_selector.parse_option(opts[:output])
  fmt_opts[:cols] = cols

  groups = cg_add_stats(
    c.cmd_data!(:group_list, **cmd_opts),
    ->(g) { g[:full_path] },
    cols,
    gopts[:parsable]
  )
  c.close

  cg_add_raw_cgroup_params(
    groups,
    ->(g) { g[:full_path] },
    cols & cgparams.map(&:to_sym)
  )

  format_output(groups, **fmt_opts)
end

#set_attr ⇒ Object

# File 'lib/osctl/cli/group.rb', line 232

def set_attr
  require_args!('name', 'attribute', 'value')
  do_set_attr(
    :group_set,
    { name: args[0], pool: gopts[:pool] },
    args[1],
    args[2]
  )
end

#set_cpu_limit ⇒ Object

# File 'lib/osctl/cli/group.rb', line 199

def set_cpu_limit
  require_args!('name', 'limit')
  do_set_cpu_limit(:group_cgparam_set, name: args[0], pool: gopts[:pool])
end

#set_memory_limit ⇒ Object

# File 'lib/osctl/cli/group.rb', line 213

def set_memory_limit
  require_args!('name', 'memory', optional: %w[swap])
  do_set_memory(
    :group_cgparam_set,
    :group_cgparam_unset,
    name: args[0],
    pool: gopts[:pool]
  )
end

#show ⇒ Object

# File 'lib/osctl/cli/group.rb', line 115

def show
  c = osctld_open
  cg_init_subsystems(c)

  cgparams = cg_list_raw_cgroup_params

  param_selector = OsCtl::Lib::Cli::ParameterSelector.new(
    all_params: FIELDS + cgparams,
    default_params: DEFAULT_FIELDS
  )

  if opts[:list]
    puts param_selector
    return
  end

  require_args!('name')

  cols = param_selector.parse_option(opts[:output])

  fmt_opts = {
    layout: :rows,
    cols:,
    opts: {
      memory_limit: {
        align: 'right',
        display: proc do |v|
          if v.nil? || gopts[:parsable] || gopts[:json]
            v
          else
            humanize_data(v)
          end
        end
      },
      swap_limit: {
        align: 'right',
        display: proc do |v|
          if v.nil? || gopts[:parsable] || gopts[:json]
            v
          else
            humanize_data(v)
          end
        end
      }
    }
  }
  fmt_opts[:header] = false if opts['hide-header']

  group = c.cmd_data!(:group_show, name: args[0], pool: gopts[:pool])
  cg_add_stats(
    group,
    group[:full_path],
    cols,
    gopts[:parsable]
  )
  c.close

  cg_add_raw_cgroup_params(
    group,
    group[:full_path],
    cols & cgparams.map(&:to_sym)
  )

  format_output(group, **fmt_opts)
end

#tree ⇒ Object

# File 'lib/osctl/cli/group.rb', line 110

def tree
  require_args!('pool')
  Tree.print(args[0], parsable: gopts[:parsable], color: gopts[:color])
end

#unset_attr ⇒ Object

# File 'lib/osctl/cli/group.rb', line 242

def unset_attr
  require_args!('name', 'attribute')
  do_unset_attr(
    :group_unset,
    { name: args[0], pool: gopts[:pool] },
    args[1]
  )
end

#unset_cpu_limit ⇒ Object

# File 'lib/osctl/cli/group.rb', line 204

def unset_cpu_limit
  require_args!('name')
  do_unset_cpu_limit(
    :group_cgparam_unset,
    name: args[0],
    pool: gopts[:pool]
  )
end

#unset_memory_limit ⇒ Object

# File 'lib/osctl/cli/group.rb', line 223

def unset_memory_limit
  require_args!('name')
  do_unset_memory(
    :group_cgparam_unset,
    name: args[0],
    pool: gopts[:pool]
  )
end