mark anomalous metrics as such

analyze/threesigma.go

@@ -46,6 +46,7 @@ func (t *ThreeSigma) Run() {
 				MetricName: fmt.Sprintf("anode.threesig.%s.anomalous", d.MetricName),
 				Timestamp:  d.Timestamp,
 				Value:      ma,
+				IsAnamoly:  true,
 			}
 		}
 
@@ -54,18 +55,21 @@ func (t *ThreeSigma) Run() {
 			MetricName: fmt.Sprintf("anode.threesig.%s.mean", d.MetricName),
 			Timestamp:  d.Timestamp,
 			Value:      mean,
+			IsAnamoly:  false,
 		}
 
 		// Output mean +/- 3 standard deviations.
 		t.output <- data.Datapoint{
 			MetricName: fmt.Sprintf("anode.threesig.%s.upper", d.MetricName),
 			Timestamp:  d.Timestamp,
 			Value:      t.stats.Mean() + 3*stddev,
+			IsAnamoly:  false,
 		}
 		t.output <- data.Datapoint{
 			MetricName: fmt.Sprintf("anode.threesig.%s.lower", d.MetricName),
 			Timestamp:  d.Timestamp,
 			Value:      t.stats.Mean() - 3*stddev,
+			IsAnamoly:  false,
 		}
 	}
 }

data/data.go

@@ -4,4 +4,5 @@ type Datapoint struct {
 	MetricName string
 	Timestamp  int64
 	Value      float64
+	IsAnomaly  bool
 }