feat(traces): migrate to embed.TraceConsumer + ProducerModule with realistic per-span emission timing (PIPE-1024)

cmd/blitz/main.go

@@ -408,7 +408,18 @@ func createGenerator(logger *zap.Logger, genCfg config.Generator, out output.Out
 	case config.GeneratorTypeWinevt:
 		return winevt.New(logger, genCfg.Winevt.Workers, genCfg.Winevt.Rate)
 	case config.GeneratorTypeTraces:
-		return tracesgen.New(logger, genCfg.Traces.Workers, genCfg.Traces.Rate)
+		tw, ok := out.(output.TraceWriter)
+		if !ok {
+			return nil, fmt.Errorf("traces requires an output that supports TraceWriter; configured output does not")
+		}
+		return tracesgen.New(tracesgen.Config{
+			Logger:   logger,
+			Workers:  genCfg.Traces.Workers,
+			Rate:     genCfg.Traces.Rate,
+			Hostname: genCfg.Traces.Hostname,
+			Consumer: output.WriterAsTraceConsumer(tw),
+			Seed:     genCfg.Traces.Seed,
+		})
 	}
 
 	// All remaining (embed-eligible) types go through the canonical

generator/generator.go

@@ -1,24 +1 @@
 package generator
-
-import (
-	"context"
-
-	"github.com/observiq/blitz/output"
-	"github.com/observiq/blitz/telemetry"
-)
-
-// TraceGenerator is the legacy interface for generating trace data.
-// Retained until generator/traces migrates to embed.TraceConsumer
-// (PIPE-1024); will be removed in that PR alongside the traces
-// migration.
-type TraceGenerator interface {
-	// Start starts the trace generator and writes data using the
-	// provided trace writer.
-	Start(writer output.TraceWriter) error
-
-	// Stop stops the trace generator.
-	Stop(ctx context.Context) error
-
-	// SupportedTelemetry returns the telemetry types this generator produces.
-	SupportedTelemetry() []telemetry.Type
-}