Function loggingMiddleware

src/libraries/go/lib/pkg/core/httpservice.go:484–508

(rootCtx context.Context)

func telemetryAttributesMiddleware(additionalAttributes []attribute.KeyValue) mux.MiddlewareFunc {
	return func(next http.Handler) http.Handler {
		return http.HandlerFunc(func(rw http.ResponseWriter, r *http.Request) {
			trace.SpanFromContext(r.Context()).SetAttributes(additionalAttributes...)
			next.ServeHTTP(rw, r)
		})
	}
}

func loggingMiddleware(rootCtx context.Context) mux.MiddlewareFunc {
	return func(next http.Handler) http.Handler {
		return http.HandlerFunc(func(rw http.ResponseWriter, r *http.Request) {
			reqID := nextRequestID(rootCtx, &httpReqSequenceID)
			logFields := map[string]interface{}{
				"path":        r.URL.Path,
				"method":      r.Method,
				"ip":          r.RemoteAddr,
				"http_req_id": reqID,
			}
			// Retrieve the span and trace IDs if they exist and log them
			spanCtx := trace.SpanContextFromContext(r.Context())
			if spanCtx.HasSpanID() {
				logFields["span_id"] = spanCtx.SpanID().String()
			}
			if spanCtx.HasTraceID() {
				logFields["trace_id"] = spanCtx.TraceID().String()
			}

			// Create new logger with fields and pass along
			requestLogger := GetLogger(rootCtx).WithFields(logFields)