Checks + structure for alerting

src/metrics-alerting/alert/alert.go

+package alert
+
+import (
+	"fmt"
+
+	"metrics-alerting/config"
+	"metrics-alerting/warp10"
+)
+
+func ProcessNumber(client warp10.Warp10Client, script config.Script) error {
+	value, err := client.ReadNumber(script.Script)
+	if err != nil {
+		return err
+	}
+
+	if value < script.Threshold {
+		// Nothing to alert about
+		return nil
+	}
+
+	return alert(script, value)
+}
+
+func ProcessBool(client warp10.Warp10Client, script config.Script) error {
+	value, err := client.ReadBool(script.Script)
+	if err != nil {
+		return err
+	}
+
+	if value {
+		return nil
+	}
+
+	return alert(script, value)
+}
+
+func alert(script config.Script, result interface{}) error {
+	switch script.Action {
+	case "http":
+		return alertHttp(script, result)
+	case "email":
+		return alertEmail(script, result)
+	default:
+		return fmt.Errorf("invalid action type: %s", script.Action)
+	}
+}

src/metrics-alerting/alert/email.go

+package alert
+
+import (
+	"metrics-alerting/config"
+)
+
+func alertEmail(script config.Script, result interface{}) error {
+	return nil
+}

src/metrics-alerting/alert/http.go

+package alert
+
+import (
+	"metrics-alerting/config"
+)
+
+func alertHttp(script config.Script, result interface{}) error {
+	return nil
+}

src/metrics-alerting/config/config.go

 	// The type of the value returned by the script
 	Type string `yaml:"type"`
 	// Value above which an action is required
-	Threshold string `yaml:"threshold,omitempty"`
+	Threshold float64 `yaml:"threshold,omitempty"`
 	// The action to take (either "http" or "email")
 	Action string `yaml:"action"`
 	// The action's target

src/metrics-alerting/main.go

 import (
 	"flag"
 	"fmt"
+	"log"
 
+	"metrics-alerting/alert"
 	"metrics-alerting/config"
 	"metrics-alerting/warp10"
 )
 	}
 
 	for _, script := range cfg.Scripts {
+		var err error
+		switch script.Type {
+		case "number":
+			err = alert.ProcessNumber(client, script)
+			break
+		case "bool":
+			err = alert.ProcessBool(client, script)
+			break
+		default:
+			err = fmt.Errorf("invalid return type: %s", script.Type)
+		}
+
+		if err != nil {
+			log.Fatal(err)
+		}
 	}
 }