Fix metric timings

Signed-off-by: Daniel González Lopes <[email protected]>

.gitignore

@@ -1,2 +1,3 @@
 .env
-k6
+k6
+vendor

go.mod

@@ -10,7 +10,7 @@ require (
 	github.com/onsi/gomega v1.10.5 // indirect
 	github.com/pkg/errors v0.9.1
 	github.com/prometheus/prometheus v1.8.2-0.20210621150501-ff58416a0b02
-	github.com/xhit/go-str2duration/v2 v2.0.0 // indirect
+	github.com/xhit/go-str2duration/v2 v2.0.0
 	go.k6.io/k6 v0.32.0
 	golang.org/x/sys v0.0.0-20210630005230-0f9fa26af87c // indirect
 )

remote_write.go

@@ -86,9 +86,10 @@ func (c *Client) Store(ctx context.Context, ts []Timeseries) (http.Response, err
 		return http.Response{}, errors.New("State is nil")
 	}
 
+	now := time.Now()
 	stats.PushIfNotDone(ctx, state.Samples, stats.Sample{
 		Metric: RemoteWriteNumSeries,
-		Time:   time.Time{},
+		Time:   now,
 		Value:  float64(len(batch)),
 	})
 
@@ -134,16 +135,17 @@ func (c *Client) send(ctx context.Context, state *lib.State, req []byte) (http.R
 	defer cancel()
 
 	httpReq = httpReq.WithContext(ctx)
+	now := time.Now()
 
 	stats.PushIfNotDone(ctx, state.Samples, stats.Sample{
 		Metric: RemoteWriteReqs,
-		Time:   time.Time{},
+		Time:   now,
 		Value:  float64(1),
 	})
 
 	stats.PushIfNotDone(ctx, state.Samples, stats.Sample{
 		Metric: metrics.DataSent,
-		Time:   time.Time{},
+		Time:   now,
 		Value:  float64(binary.Size(req)),
 	})
 
@@ -156,14 +158,14 @@ func (c *Client) send(ctx context.Context, state *lib.State, req []byte) (http.R
 
 	stats.PushIfNotDone(ctx, state.Samples, stats.Sample{
 		Metric: RemoteWriteReqDuration,
-		Time:   time.Time{},
+		Time:   now,
 		Value:  float64(elapsed.Milliseconds()),
 	})
 
 	if httpResp.StatusCode != http.StatusOK {
 		stats.PushIfNotDone(ctx, state.Samples, stats.Sample{
 			Metric: RemoteWriteReqFailed,
-			Time:   time.Time{},
+			Time:   now,
 			Value:  float64(1),
 		})
 	}