Merge 94e83197ca into 76b74e25d5

Signed-off-by: sarthak.tyagi <sarthaktyagi100@gmail.com>

api/prometheus/v1/api.go

@@ -601,6 +601,7 @@ type AlertingRule struct {
 	EvaluationTime float64        `json:"evaluationTime"`
 	LastEvaluation time.Time      `json:"lastEvaluation"`
 	State          string         `json:"state"`
+	Type           string         `json:"type"`
 }
 
 // RecordingRule models a recording rule.
@@ -612,6 +613,7 @@ type RecordingRule struct {
 	LastError      string         `json:"lastError,omitempty"`
 	EvaluationTime float64        `json:"evaluationTime"`
 	LastEvaluation time.Time      `json:"lastEvaluation"`
+	Type           string         `json:"type"`
 }
 
 // Alert models an active alert.
@@ -721,11 +723,13 @@ func (rg *RuleGroup) UnmarshalJSON(b []byte) error {
 
 	for _, rule := range v.Rules {
 		alertingRule := AlertingRule{}
+		alertingRule.Type = string(RuleTypeAlerting)
 		if err := json.Unmarshal(rule, &alertingRule); err == nil {
 			rg.Rules = append(rg.Rules, alertingRule)
 			continue
 		}
 		recordingRule := RecordingRule{}
+		recordingRule.Type = string(RuleTypeRecording)
 		if err := json.Unmarshal(rule, &recordingRule); err == nil {
 			rg.Rules = append(rg.Rules, recordingRule)
 			continue

api/prometheus/v1/api_test.go

@@ -717,20 +717,22 @@ func TestAPIs(t *testing.T) {
 								"annotations": map[string]interface{}{
 									"summary": "High request latency",
 								},
-								"duration": 600,
-								"health":   "ok",
 								"labels": map[string]interface{}{
 									"severity": "page",
 								},
-								"name":  "HighRequestLatency",
+								"duration":  600,
-								"query": "job:request_latency_seconds:mean5m{job=\"myjob\"} > 0.5",
+								"health":    "ok",
-								"type":  "alerting",
+								"name":      "HighRequestLatency",
+								"query":     "job:request_latency_seconds:mean5m{job=\"myjob\"} > 0.5",
+								"lastError": "",
+								"type":      "alerting",
 							},
 							{
-								"health": "ok",
+								"health":    "ok",
-								"name":   "job:http_inprogress_requests:sum",
+								"name":      "job:http_inprogress_requests:sum",
-								"query":  "sum(http_inprogress_requests) by (job)",
+								"query":     "sum(http_inprogress_requests) by (job)",
-								"type":   "recording",
+								"lastError": "",
+								"type":      "recording",
 							},
 						},
 					},
@@ -769,12 +771,14 @@ func TestAPIs(t *testing.T) {
 								Name:      "HighRequestLatency",
 								Query:     "job:request_latency_seconds:mean5m{job=\"myjob\"} > 0.5",
 								LastError: "",
+								Type:      string(RuleTypeAlerting),
 							},
 							RecordingRule{
 								Health:    RuleHealthGood,
 								Name:      "job:http_inprogress_requests:sum",
 								Query:     "sum(http_inprogress_requests) by (job)",
 								LastError: "",
+								Type:      string(RuleTypeRecording),
 							},
 						},
 					},
@@ -861,14 +865,14 @@ func TestAPIs(t *testing.T) {
 								Annotations: model.LabelSet{
 									"summary": "High request latency",
 								},
+								Duration: 600,
+								Health:   RuleHealthGood,
 								Labels: model.LabelSet{
 									"severity": "page",
 								},
-								Duration:       600,
-								Health:         RuleHealthGood,
 								Name:           "HighRequestLatency",
 								Query:          "job:request_latency_seconds:mean5m{job=\"myjob\"} > 0.5",
-								LastError:      "",
+								Type:           string(RuleTypeAlerting),
 								EvaluationTime: 0.5,
 								LastEvaluation: time.Date(2020, 5, 18, 15, 52, 53, 450311300, time.UTC),
 								State:          "firing",
@@ -877,7 +881,7 @@ func TestAPIs(t *testing.T) {
 								Health:         RuleHealthGood,
 								Name:           "job:http_inprogress_requests:sum",
 								Query:          "sum(http_inprogress_requests) by (job)",
-								LastError:      "",
+								Type:           string(RuleTypeRecording),
 								EvaluationTime: 0.3,
 								LastEvaluation: time.Date(2020, 5, 18, 15, 52, 53, 450311300, time.UTC),
 							},

prometheus/histogram_test.go

@@ -382,6 +382,7 @@ func TestHistogramAtomicObserve(t *testing.T) {
 				return
 			default:
 				his.Observe(1)
+				time.Sleep(time.Nanosecond)
 			}
 		}
 	}