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
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
 
# 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 = JSON.parse(alarms.body)

    # system CPU stats
    cpu_opts = {
      "chart" => "system.cpu",
      "format" => "array",
      "points" => 54,
      "group" => "average",
      "options" => "absolute|jsonwrap|nonzero",
      "after" => -540
    }
    cpu = @network.get("data", url, cpu_opts)
    cpu_value = JSON.parse(cpu.body)["result"].first

    # CPU on a per-user basis
    users_cpu_opts = {
      "chart" => "users.cpu",
      "format" => "array",
      "points" => 54,
      "group" => "average",
      "options" => "absolute|jsonwrap|nonzero",
      "after" => -540
    }
    users_cpu = @network.get("data", url, users_cpu_opts)
    users_cpu_resp = JSON.parse(users_cpu.body)
    users_cpu_value = users_cpu_resp["result"].first
    users_cpu_value_history = users_cpu_resp["result"][0..119]
    users_cpu_users = users_cpu_resp["dimension_names"]

    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"].empty?
  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" if data[:alarms]
      message += "#{data[:users_cpu][:history].size} CPU instance(s) > #{threshold}%" if data[:users_cpu][:history].size > 0

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