Merge branch 'dev' into review_logging

pkg/archive/archive.go

@@ -102,7 +102,7 @@ func GetHandle() ArchiveBackend {
 	return ar
 }
 
-// Helper to metricdata.LoadAverages().
+// Helper to metricdataloader.LoadAverages().
 func LoadAveragesFromArchive(
 	job *schema.Job,
 	metrics []string,
@@ -125,6 +125,35 @@ func LoadAveragesFromArchive(
 	return nil
 }
 
+// Helper to metricdataloader.LoadStatData().
+func LoadStatsFromArchive(
+	job *schema.Job,
+	metrics []string,
+) (map[string]schema.MetricStatistics, error) {
+	data := make(map[string]schema.MetricStatistics, len(metrics))
+	metaFile, err := ar.LoadJobMeta(job)
+	if err != nil {
+		log.Warn("Error while loading job metadata from archiveBackend")
+		return data, err
+	}
+
+	for _, m := range metrics {
+		stat, ok := metaFile.Statistics[m]
+		if !ok {
+			data[m] = schema.MetricStatistics{Min: 0.0, Avg: 0.0, Max: 0.0}
+			continue
+		}
+
+		data[m] = schema.MetricStatistics{
+			Avg: stat.Avg,
+			Min: stat.Min,
+			Max: stat.Max,
+		}
+	}
+
+	return data, nil
+}
+
 func GetStatistics(job *schema.Job) (map[string]schema.JobStatistics, error) {
 	metaFile, err := ar.LoadJobMeta(job)
 	if err != nil {

pkg/schema/metrics.go

@@ -291,6 +291,21 @@ func (jd *JobData) AddNodeScope(metric string) bool {
 	return true
 }
 
+func (jd *JobData) RoundMetricStats() {
+	// TODO: Make Digit-Precision Configurable? (Currently: Fixed to 2 Digits)
+	for _, scopes := range *jd {
+		for _, jm := range scopes {
+			for index := range jm.Series {
+				jm.Series[index].Statistics = MetricStatistics{
+					Avg: (math.Round(jm.Series[index].Statistics.Avg*100) / 100),
+					Min: (math.Round(jm.Series[index].Statistics.Min*100) / 100),
+					Max: (math.Round(jm.Series[index].Statistics.Max*100) / 100),
+				}
+			}
+		}
+	}
+}
+
 func (jm *JobMetric) AddPercentiles(ps []int) bool {
 	if jm.StatisticsSeries == nil {
 		jm.AddStatisticsSeries()