adjust metrics output formats to normalize on nanoseconds since epoch…

… for time and nanoseconds for durations
josephcopenhaver · Aug 8, 2024 · f96167c · f96167c
1 parent b72174b
commit f96167c
Show file tree

Hide file tree

Showing 6 changed files with 311 additions and 226 deletions.
diff --git a/docs/metrics.md b/docs/metrics.md
diff --git a/loadtester/csv_metrics.go b/loadtester/csv_metrics.go
@@ -5,6 +5,7 @@ import (
 	"encoding/json"
 	"io"
 	"os"
+	"strconv"
 	"sync"
 	"time"
 )
@@ -57,10 +58,6 @@ func (lt *Loadtest) writeOutputCsvConfigComment(w io.Writer) error {
 		return err
 	}
 
-	if _, err := w.Write([]byte("\n")); err != nil {
-		return err
-	}
-
 	return nil
 }
 
@@ -170,7 +167,7 @@ func (lt *Loadtest) writeOutputCsvFooterAndClose(csvFile *os.File) {
 		return
 	}
 
-	_, cd.writeErr = csvFile.Write([]byte("\n# {\"done\":{\"end_time\":\"" + timeToString(time.Now()) + "\"}}\n"))
+	_, cd.writeErr = csvFile.Write([]byte("# {\"done\":{\"end_time\":\"" + timeToString(time.Now()) + "\"}}"))
 }
 
 //
@@ -180,3 +177,11 @@ func (lt *Loadtest) writeOutputCsvFooterAndClose(csvFile *os.File) {
 func timeToString(t time.Time) string {
 	return t.UTC().Format(time.RFC3339Nano)
 }
+
+func timeToUnixNanoString(t time.Time) string {
+	return strconv.FormatInt(t.UnixNano(), 10)
+}
+
+func durationToNanoString(d time.Duration) string {
+	return strconv.FormatInt(d.Nanoseconds(), 10)
+}