Use status.code as attribute

open-telemetry · Sep 13, 2023 · 82537b4 · 82537b4
1 parent 2487539
commit 82537b4
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 5 deletions.
diff --git a/cmd/telemetrygen/internal/metrics/metrics.go b/cmd/telemetrygen/internal/metrics/metrics.go
@@ -112,7 +112,7 @@ func Run(c *Config, exp sdkmetric.Exporter, logger *zap.Logger) error {
 			index:          i,
 		}
 
-		go w.simulateMetrics(res, exp, c.GetAttributes())
+		go w.simulateMetrics(res, exp)
 	}
 	if c.TotalDuration > 0 {
 		time.Sleep(c.TotalDuration)

diff --git a/cmd/telemetrygen/internal/metrics/worker.go b/cmd/telemetrygen/internal/metrics/worker.go
@@ -27,12 +27,15 @@ type worker struct {
 	index          int             // worker index
 }
 
-func (w worker) simulateMetrics(res *resource.Resource, exporter sdkmetric.Exporter, attributes []attribute.KeyValue) {
+func (w worker) simulateMetrics(res *resource.Resource, exporter sdkmetric.Exporter) {
 	limiter := rate.NewLimiter(w.limitPerSecond, 1)
 
 	var i int64
 	value := 24.42
-	attrs := attribute.NewSet(attributes...)
+	attrs := attribute.NewSet(attribute.KeyValue{
+		Key:   attribute.Key("status.code"),
+		Value: attribute.StringValue("STATUS_CODE_OK"),
+	})
 
 	for w.running.Load() {
 		rm := metricdata.ResourceMetrics{
@@ -46,8 +49,8 @@ func (w worker) simulateMetrics(res *resource.Resource, exporter sdkmetric.Expor
 								DataPoints: []metricdata.DataPoint[int64]{
 									{
 										Attributes: attrs,
-										Time:       time.Now(),
-										Value:      i,
+										Time:  time.Now(),
+										Value: i,
 									},
 								},
 							},