Function handleHTTPGRPCRequestWithOTel

middleware/http_tracing.go:255–289

(ctx context.Context, req any, httpRequest *http.Request, router *mux.Router, handler grpc.UnaryHandler)

}

func handleHTTPGRPCRequestWithOTel(ctx context.Context, req any, httpRequest *http.Request, router *mux.Router, handler grpc.UnaryHandler) (any, error) {
	// extract relevant span & tag data from request
	method := httpRequest.Method
	routeName := getRouteName(router, httpRequest)
	urlPath := httpRequest.URL.Path
	userAgent := httpRequest.Header.Get("User-Agent")

	parentSpan := trace.SpanFromContext(ctx)
	if parentSpan.SpanContext().IsValid() {
		parentSpan.SetAttributes(
			semconv.HTTPRequestMethodKey.String(method),
			semconv.HTTPRouteKey.String(routeName),
			attribute.String("url.path", urlPath),
			semconv.UserAgentOriginal(userAgent),
		)
	}
	// create and start child HTTP span and set span name and attributes
	childSpanName := getOperationName(routeName, httpRequest)

	startSpanOpts := []trace.SpanStartOption{
		trace.WithSpanKind(trace.SpanKindServer),
		trace.WithAttributes(
			semconv.HTTPRequestMethodKey.String(method),
			semconv.HTTPRouteKey.String(routeName),
			semconv.UserAgentOriginal(userAgent),
			attribute.String("url.path", urlPath),
		),
	}

	var childSpan trace.Span
	ctx, childSpan = tracer.Start(ctx, childSpanName, startSpanOpts...)
	defer childSpan.End()

	return handler(ctx, req)
}

func httpOperationName(r *http.Request) string {
	routeName := ExtractRouteName(r.Context())