Add Metric.Emit

lib/executor/ramping_arrival_rate.go

@@ -482,10 +482,7 @@ func (varr RampingArrivalRate) Run(
 		// Since there aren't any free VUs available, consider this iteration
 		// dropped - we aren't going to try to recover it, but
 
-		stats.PushIfNotDone(parentCtx, out, stats.Sample{
-			Value: 1, Metric: droppedIterationMetric,
-			Tags: metricTags, Time: time.Now(),
-		})
+		stats.PushIfNotDone(parentCtx, out, droppedIterationMetric.Emit(time.Now(), metricTags, 1))
 
 		// We'll try to start allocating another VU in the background,
 		// non-blockingly, if we have remainingUnplannedVUs...

stats/stats.go

@@ -450,6 +450,16 @@ type Metric struct {
 	Sink       Sink         `json:"-"`
 }
 
+// Emit a sample for the metric at the given time, with the provided tags and values
+func (m *Metric) Emit(t time.Time, tags *SampleTags, value float64) Sample {
+	return Sample{
+		Time:   t,
+		Tags:   tags,
+		Value:  value,
+		Metric: m,
+	}
+}
+
 func New(name string, typ MetricType, t ...ValueType) *Metric {
 	vt := Default
 	if len(t) > 0 {