Clusterchecks mit Icinga2

clustercheck.cpp

object CheckCommand "clustercheck" {
  import "plugin-check-command"
  command = {{
    var cmd = [ PluginDir + "/check_dummy" ]
    var cluster_nodes = macro("$cluster_nodes$")
    var host_failed = [ ]
    for (cluster_node in cluster_nodes) {
        log("Check state of " + cluster_node)
        /* get host state from node */
        var host = get_host(cluster_node)
        /* wenn der Host kritisch ist zählen wir den Fehlerwert hoch
           und speichern den kritischen Host in einer Variable */
        if (host.state_raw != 0 && host.state_raw != 1) {
          log(cluster_node + " failed")
          host_failed += [ cluster_node ]
        }
    }
    if (len(host_failed) >= number(macro("$cluster_critical$"))) {
        cmd += [ "2", "Cluster ist in einem kritischen Zustand. Kritische Hosts: " + host_failed.join(",") ]
    } else {
        if (len(host_failed) >= 1) {
          cmd += [ "0", "Cluster hat Probleme. Kritische Hosts: " + host_failed.join(",") ]
        } else {
          cmd += [0, "Cluster ist OK"]
        }
    }
    return cmd
  }}
}
object Host "node1" {
  import "generic-host"
  address = "127.0.0.1"
}
object Host "node2" {
  import "generic-host"
  address = "127.0.0.1"
}
object Host "node3" {
  import "generic-host"
  address = "192.100.213.2"
}
object Host "cluster" {
  import "generic-host"
  check_command = "clustercheck"
  /* unser cluster ist kritisch wenn mehr als 2 Hosts weg sind */
  vars.cluster_critical = "2"
  vars.cluster_nodes = [
    "node1",
    "node2",
    "node3"
  ]
  check_interval = 10s
}