Validate labels and annotations

Signed-off-by: Goutham Veeramachaneni <cs14btech11014@iith.ac.in>

pkg/rulefmt/rulefmt.go

@@ -18,6 +18,7 @@ import (
 
 	"github.com/ghodss/yaml"
 	"github.com/pkg/errors"
+	"github.com/prometheus/common/model"
 	"github.com/prometheus/prometheus/promql"
 )
 
@@ -111,6 +112,23 @@ func (r *Rule) Validate() (errs []error) {
 			errs = append(errs, errors.Errorf("invalid field 'for' in recording rule"))
 		}
 	}
+
+	for k, v := range r.Labels {
+		if !model.LabelName(k).IsValid() {
+			errs = append(errs, errors.Errorf("invalid label name: %s", k))
+		}
+
+		if !model.LabelValue(v).IsValid() {
+			errs = append(errs, errors.Errorf("invalid label value: %s", v))
+		}
+	}
+
+	for k := range r.Annotations {
+		if !model.LabelName(k).IsValid() {
+			errs = append(errs, errors.Errorf("invalid annotation name: %s", k))
+		}
+	}
+
 	return errs
 }
 

pkg/rulefmt/rulefmt_test.go

@@ -57,6 +57,14 @@ func TestParseFileFailure(t *testing.T) {
 			filename: "noexpr.bad.yaml",
 			errMsg:   "field 'expr' must be set in rule",
 		},
+		{
+			filename: "bad_lname.bad.yaml",
+			errMsg:   "invalid label name",
+		},
+		{
+			filename: "bad_annotation.bad.yaml",
+			errMsg:   "invalid annotation name",
+		},
 	}
 
 	for _, c := range table {

pkg/rulefmt/testdata/bad_annotation.bad.yaml

@@ -0,0 +1,8 @@
+Version: 1
+Groups:
+  - name: yolo
+    rules:
+    - alert: hola
+      expr: 1
+      annotations:
+        ins-tance: localhost 

pkg/rulefmt/testdata/bad_lname.bad.yaml

@@ -0,0 +1,8 @@
+Version: 1
+Groups:
+  - name: yolo
+    rules:
+      - record: hola
+        expr: 1
+        labels:
+          ins-tance: localhost

pkg/rulefmt/testdata/test.yaml

@@ -6,7 +6,8 @@ groups:
   - alert: HighErrors
     expr: |
       sum without(instance) (rate(errors_total[5m]))
-      / sum without(instance) (rate(requests_total[5m]))
+      / 
+      sum without(instance) (rate(requests_total[5m]))
     for: 5m
     labels:
       severity: critical
@@ -17,7 +18,8 @@ groups:
   - record: "new_metric"
     expr: |
       sum without(instance) (rate(errors_total[5m]))
-      / sum without(instance) (rate(requests_total[5m]))
+      / 
+      sum without(instance) (rate(requests_total[5m]))
     labels:
       abc: edf
       uvw: xyz
@@ -25,7 +27,8 @@ groups:
   - alert: HighErrors
     expr: | 
       sum without(instance) (rate(errors_total[5m]))
-      / sum without(instance) (rate(requests_total[5m]))
+      / 
+      sum without(instance) (rate(requests_total[5m]))
     for: 5m
     labels:
       severity: critical
@@ -38,7 +41,8 @@ groups:
   - alert: HighErrors
     expr: | 
       sum without(instance) (rate(errors_total[5m]))
-      / sum without(instance) (rate(requests_total[5m]))
+      / 
+      sum without(instance) (rate(requests_total[5m]))
     for: 5m
     labels:
       severity: critical
@@ -46,12 +50,14 @@ groups:
   - record: "new_metric"
     expr: |
       sum without(instance) (rate(errors_total[5m]))
-      / sum without(instance) (rate(requests_total[5m]))
+      / 
+      sum without(instance) (rate(requests_total[5m]))
 
   - alert: HighErrors
     expr: | 
       sum without(instance) (rate(errors_total[5m]))
-      / sum without(instance) (rate(requests_total[5m]))
+      / 
+      sum without(instance) (rate(requests_total[5m]))
     for: 5m
     labels:
       severity: critical

rules/manager.go

@@ -267,9 +267,7 @@ func typeForRule(r Rule) ruleType {
 	panic(fmt.Errorf("unknown rule type: %T", r))
 }
 
-// Eval runs a single evaluation cycle in which all rules are evaluated in parallel.
-// In the future a single group will be evaluated sequentially to properly handle
-// rule dependency.
+// Eval runs a single evaluation cycle in which all rules are evaluated sequentially.
 func (g *Group) Eval(ts time.Time) {
 	for i, rule := range g.rules {
 		rtyp := string(typeForRule(rule))