Function basicOTelExample

examples/telemetry/main.go:43–100

basicOTelExample 演示基础 OpenTelemetry 集成

()

// basicOTelExample 演示基础 OpenTelemetry 集成
func basicOTelExample() {
	ctx := context.Background()

	// 1. 创建 stdout exporter（用于演示）
	exporter, err := stdouttrace.New(
		stdouttrace.WithWriter(os.Stdout),
		stdouttrace.WithPrettyPrint(),
	)
	if err != nil {
		log.Fatalf("Failed to create exporter: %v", err)
	}

	// 2. 创建 OTel tracer
	tracer, err := telemetry.NewOTelTracer(
		"my-agent-service",
		telemetry.WithOTelExporter(exporter),
		telemetry.WithOTelServiceVersion("1.0.0"),
		telemetry.WithOTelSampler(sdktrace.AlwaysSample()),
		telemetry.WithOTelAttributes(
			attribute.String("environment", "development"),
			attribute.String("deployment", "local"),
		),
	)
	if err != nil {
		log.Fatalf("Failed to create tracer: %v", err)
	}
	defer func() { _ = tracer.Shutdown(ctx) }()

	// 3. 设置为全局 tracer
	telemetry.SetGlobalTracer(tracer)

	// 4. 创建 span
	_, span := tracer.StartSpan(
		ctx,
		"basic-operation",
		telemetry.WithSpanKind(telemetry.SpanKindInternal),
	)
	defer span.End()

	// 5. 添加属性
	span.SetAttributes(
		telemetry.String("operation.type", "example"),
		telemetry.Int("operation.count", 1),
	)

	// 6. 模拟一些工作
	time.Sleep(100 * time.Millisecond)

	// 7. 添加事件
	span.AddEvent("operation.completed",
		telemetry.String("result", "success"),
	)

	// 8. 设置状态
	span.SetStatus(telemetry.StatusCodeOK, "Operation completed successfully")

	fmt.Println("✅ Basic OTel integration completed")
}