k6runner: create spans for sending logs and metrics

Author: nadiamoe

internal/k6runner/k6runner.go

@@ -18,6 +18,7 @@ import (
 	"github.com/rs/zerolog"
 	"github.com/spf13/afero"
 	"go.opentelemetry.io/otel/attribute"
+	"go.opentelemetry.io/otel/trace"
 )
 
 // Script is a k6 script that a runner is able to run, with some added instructions for that runner to act on.
@@ -147,32 +148,42 @@ func (r Processor) Run(ctx context.Context, registry *prometheus.Registry, logge
 		}()
 	}
 
+	_, sendLogsSpan := trace.SpanFromContext(ctx).TracerProvider().Tracer("").Start(ctx, "send logs")
 	// Send logs before metrics to make sure logs are submitted even if the metrics output is not parsable.
 	if err := k6LogsToLogger(result.Logs, logger); err != nil {
 		internalLogger.Debug().
 			Err(err).
 			Msg("cannot load logs to logger")
+		sendLogsSpan.RecordError(err)
+		sendLogsSpan.End()
 		return false, err
 	}
+	sendLogsSpan.End()
 
 	var (
 		collector       sampleCollector
 		resultCollector checkResultCollector
 	)
 
+	_, sendMetricsSpan := trace.SpanFromContext(ctx).TracerProvider().Tracer("").Start(ctx, "send metrics")
 	if err := extractMetricSamples(result.Metrics, internalLogger, collector.process, resultCollector.process); err != nil {
 		internalLogger.Debug().
 			Err(err).
 			Msg("cannot extract metric samples")
+		sendMetricsSpan.RecordError(err)
+		sendMetricsSpan.End()
 		return false, err
 	}
 
 	if err := registry.Register(&collector.collector); err != nil {
 		internalLogger.Error().
 			Err(err).
 			Msg("cannot register collector")
+		sendMetricsSpan.RecordError(err)
+		sendMetricsSpan.End()
 		return false, err
 	}
+	sendMetricsSpan.End()
 
 	// https://github.com/grafana/sm-k6-runner/blob/b811839d444a7e69fd056b0a4e6ccf7e914197f3/internal/mq/runner.go#L51
 	switch result.ErrorCode {