Function distributedTracingExample

examples/telemetry/main.go:223–264

distributedTracingExample 演示分布式追踪

()

// distributedTracingExample 演示分布式追踪
func distributedTracingExample() {
	ctx := context.Background()
	tracer := telemetry.GetGlobalTracer()

	// Service A: 创建一个 span
	ctx, spanA := tracer.StartSpan(
		ctx,
		"service-a.process",
		telemetry.WithSpanKind(telemetry.SpanKindServer),
	)

	// 模拟将 trace context 传播到 Service B
	carrier := make(MapCarrier)
	if err := tracer.Inject(ctx, carrier); err != nil {
		log.Printf("Failed to inject context: %v", err)
	}

	spanA.AddEvent("context.injected",
		telemetry.String("carrier.type", "http-headers"),
	)

	// Service B: 提取 trace context
	ctxB := context.Background()
	ctxB = tracer.Extract(ctxB, carrier)

	_, spanB := tracer.StartSpan(
		ctxB,
		"service-b.handle",
		telemetry.WithSpanKind(telemetry.SpanKindServer),
	)

	spanB.AddEvent("context.extracted")
	time.Sleep(50 * time.Millisecond)

	spanB.SetStatus(telemetry.StatusCodeOK, "Service B completed")
	spanB.End()

	spanA.SetStatus(telemetry.StatusCodeOK, "Service A completed")
	spanA.End()

	fmt.Println("✅ Distributed tracing completed")
}

// 辅助函数