辅助函数
(ctx context.Context, _ telemetry.Span)
| 266 | // 辅助函数 |
| 267 | |
| 268 | func processMiddleware(ctx context.Context, _ telemetry.Span) { |
| 269 | tracer := telemetry.GetGlobalTracer() |
| 270 | |
| 271 | middlewares := []string{"auth", "rate-limit", "logging"} |
| 272 | for _, mw := range middlewares { |
| 273 | _, span := tracer.StartSpan( |
| 274 | ctx, |
| 275 | "middleware."+mw, |
| 276 | telemetry.WithSpanKind(telemetry.SpanKindInternal), |
| 277 | ) |
| 278 | |
| 279 | time.Sleep(10 * time.Millisecond) |
| 280 | span.SetStatus(telemetry.StatusCodeOK, mw+" passed") |
| 281 | span.End() |
| 282 | } |
| 283 | } |
| 284 | |
| 285 | func processLLM(ctx context.Context, _ telemetry.Span) { |
| 286 | tracer := telemetry.GetGlobalTracer() |
no test coverage detected