Class: Netdata::Client::Controller

Inherits:
Object
  • Object
show all
Defined in:
lib/netdata/client/controller.rb

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Controller

Returns a new instance of Controller.



4
5
6
7
 
# File 'lib/netdata/client/controller.rb', line 4

def initialize
  @network = Helper::Network.new
  @config = ::YAML::load_file(File.expand_path("~/.netdatacli.yml"))
end

Instance Method Details

#report_interval_2_mins ⇒ Object 



9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
 
# File 'lib/netdata/client/controller.rb', line 9

def report_interval_2_mins
  aggregator = {}
  threshold = 50 # numbers higher than this should trigger notifications

  return unless @config

  @config["instances"].each do |url|
    alarms = @network.get("alarms", url, {})

    return unless alarms

    alarms_resp = parse_alarms(JSON.parse(alarms.body))

    # system CPU stats
    cpu_value = get_cpu(url)

    # CPU on a per-user basis
    users_cpu_value_history, users_cpu_value, users_cpu_users = get_cpu_users(url)

    aggregator[alarms_resp["hostname"]] = {}
    aggregator[alarms_resp["hostname"]][:cpu] = cpu_value
    aggregator[alarms_resp["hostname"]][:users_cpu] = { users: users_cpu_users, value: users_cpu_value, history: users_cpu_value_history.select { |val| val > threshold } }
    aggregator[alarms_resp["hostname"]][:alarms] = alarms_resp unless alarms_resp["alarms"].nil?
  end

  pp aggregator

  aggregator.each_pair do |host, data|
    # new thread for each host so we can see mulitple notifications
    Thread.new {
      message = ""
      message += "CPU Warning - #{data[:cpu].round(2)}%\n" if data[:cpu] > threshold
      message += "#{data[:users_cpu][:users].size} system users active (#{data[:users_cpu][:value].round(2)}% CPU)\n" if data[:users_cpu][:value] > threshold
      message += "Alarms are ringing\n" if data[:alarms]
      message += "#{data[:users_cpu][:history].size} CPU instance(s) > #{threshold}%\n" if data[:users_cpu][:history].size > 0

      Notify.bubble(message, "Netdata Warning on #{host}") if message.size > 0
    }.join
  end
end