[cmd/telemetrygen]: run linter over changes

cmd/telemetrygen/internal/traces/config.go

@@ -4,7 +4,7 @@
 package traces
 
 import (
- "time"
+ "time"
 
  "github.com/spf13/pflag"
 
@@ -20,7 +20,7 @@ type Config struct {
  StatusCode string
  Batch bool
  LoadSize int
- SpanDuration time.Duration
+ SpanDuration time.Duration
 }
 
 // Flags registers config flags.
@@ -35,5 +35,5 @@ func (c *Config) Flags(fs *pflag.FlagSet) {
  fs.StringVar(&c.StatusCode, "status-code", "0", "Status code to use for the spans, one of (Unset, Error, Ok) or the equivalent integer (0,1,2)")
  fs.BoolVar(&c.Batch, "batch", true, "Whether to batch traces")
  fs.IntVar(&c.LoadSize, "size", 0, "Desired minimum size in MB of string data for each trace generated. This can be used to test traces with large payloads, i.e. when testing the OTLP receiver endpoint max receive size.")
- fs.DurationVar(&c.SpanDuration, "span-duration", 123*time.Microsecond, "The duration of each generated span.")
+ fs.DurationVar(&c.SpanDuration, "span-duration", 123*time.Microsecond, "The duration of each generated span.")
 }

cmd/telemetrygen/internal/traces/traces.go

@@ -132,7 +132,7 @@ func Run(c *Config, logger *zap.Logger) error {
  wg: &wg,
  logger: logger.With(zap.Int("worker", i)),
  loadSize: c.LoadSize,
- spanDuration: c.SpanDuration,
+ spanDuration: c.SpanDuration,
  }
 
  go w.simulateTraces(telemetryAttributes)

cmd/telemetrygen/internal/traces/worker.go

@@ -28,8 +28,8 @@ type worker struct {
  totalDuration time.Duration // how long to run the test for (overrides `numTraces`)
  limitPerSecond rate.Limit // how many spans per second to generate
  wg *sync.WaitGroup // notify when done
- loadSize int // desired minimum size in MB of string data for each generated trace
- spanDuration time.Duration // duration of generated spans
+ loadSize int // desired minimum size in MB of string data for each generated trace
+ spanDuration time.Duration // duration of generated spans
  logger *zap.Logger
 }
 
@@ -45,15 +45,15 @@ func (w worker) simulateTraces(telemetryAttributes []attribute.KeyValue) {
  var i int
 
  for w.running.Load() {
- spanStart := time.Now()
- spanEnd := spanStart.Add(w.spanDuration)
+ spanStart := time.Now()
+ spanEnd := spanStart.Add(w.spanDuration)
 
- ctx, sp := tracer.Start(context.Background(), "lets-go", trace.WithAttributes(
+ ctx, sp := tracer.Start(context.Background(), "lets-go", trace.WithAttributes(
  semconv.NetPeerIPKey.String(fakeIP),
  semconv.PeerServiceKey.String("telemetrygen-server"),
  ),
  trace.WithSpanKind(trace.SpanKindClient),
- trace.WithTimestamp(spanStart),
+ trace.WithTimestamp(spanStart),
  )
  sp.SetAttributes(telemetryAttributes...)
  for j := 0; j < w.loadSize; j++ {
@@ -75,7 +75,7 @@ func (w worker) simulateTraces(telemetryAttributes []attribute.KeyValue) {
  semconv.PeerServiceKey.String("telemetrygen-client"),
  ),
  trace.WithSpanKind(trace.SpanKindServer),
- trace.WithTimestamp(spanStart),
+ trace.WithTimestamp(spanStart),
  )
  child.SetAttributes(telemetryAttributes...)