Class: WatchmonkeyCli::Checkers::UnixDefaults

Inherits:
WatchmonkeyCli::Checker show all
Defined in:
lib/watchmonkey_cli/checkers/unix_defaults.rb

Constant Summary

Constants included from Helper

Helper::BYTE_UNITS

Instance Attribute Summary

Attributes inherited from WatchmonkeyCli::Checker

#app

Instance Method Summary collapse

Methods inherited from WatchmonkeyCli::Checker

#_tolog, #blank_config, checker_name, checker_name=, #debug, descendants, #error, #info, inherited, #init, #initialize, #local, maxrt, maxrt=, #rsafe, #safe, #spawn_sub, #start, #stop

Methods included from Helper

#human_filesize, #human_number, #human_seconds

Constructor Details

This class inherits a constructor from WatchmonkeyCli::Checker

Instance Method Details

#check!(result, host, opts = {}) ⇒ Object 



32
33
34
35
36
37
38
39
40
41
42
 
# File 'lib/watchmonkey_cli/checkers/unix_defaults.rb', line 32

def check! result, host, opts = {}
  [:unix_load, :unix_memory, :unix_df, :unix_mdadm, :unix_cpu_governor].each do |which|
    # if opts[which] && sec = app.checkers[which.to_s]
    #   sec.check!(result, host, opts[which])
    # end
    # app.enqueue_sub(self, which, host, opts[which]) if opts[which]
    #spawn_sub(which, host, (opts[which].is_a?(Hash) ? opts[which] : {}).merge(tags: result.tags)) unless opts[which] == false
    stags = (opts[:tags] || []).reject{|t| t.to_s.start_with?("WMC-") }
    blank_config(stags).send(which, host, (opts[which].is_a?(Hash) ? opts[which] : {})) unless opts[which] == false
  end
end

#enqueue(host, opts = {}) ⇒ Object 



6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
 
# File 'lib/watchmonkey_cli/checkers/unix_defaults.rb', line 6

def enqueue host, opts = {}
  return if app.running? # we only ever want to run this once to spawn sub checkers
  opts = { unix_load: {}, unix_memory: {}, unix_df: {}, unix_mdadm: {}, unix_cpu_governor: {} }.merge(opts)

  host = app.fetch_connection(:loopback, :local) if !host || host == :local
  host = app.fetch_connection(:ssh, host) if host.is_a?(Symbol)

  # option shortcuts
  opts[:unix_load][:limits] = opts[:load] if opts[:load]
  opts[:unix_load] = false if opts[:load] == false
  opts[:unix_memory][:min_percent] = opts[:memory_min] if opts[:memory_min]
  opts[:unix_memory] = false if opts[:memory_min] == false
  opts[:unix_df][:min_percent] = opts[:df_min] if opts[:df_min]
  opts[:unix_df] = false if opts[:df_min] == false
  opts[:unix_mdadm] = false if opts[:mdadm] == false
  opts[:unix_cpu_governor][:expect] = opts[:cpu_governor] if opts[:cpu_governor]
  opts[:unix_cpu_governor] = false if opts[:cpu_governor] == false
  opts.delete(:load)
  opts.delete(:memory_min)
  opts.delete(:df_min)
  opts.delete(:mdadm)
  opts.delete(:cpu_governor)

  app.enqueue(self, host, opts)
end