Method logQueryRequest

pkg/frontend/transport/handler.go:384–421

logQueryRequest logs query request before query execution.

(r *http.Request, queryString url.Values, source string)

// logQueryRequest logs query request before query execution.
func (f *Handler) logQueryRequest(r *http.Request, queryString url.Values, source string) {
	logMessage := []any{
		"msg", "query request",
		"component", "query-frontend",
		"method", r.Method,
		"path", r.URL.Path,
	}
	grafanaFields := formatGrafanaStatsFields(r)
	if len(grafanaFields) > 0 {
		logMessage = append(logMessage, grafanaFields...)
	}

	if query := queryString.Get("query"); len(query) > 0 {
		logMessage = append(logMessage, "query_length", len(query))
	}

	if ua := r.Header.Get("User-Agent"); len(ua) > 0 {
		logMessage = append(logMessage, "user_agent", ua)
	}

	if engineType := r.Header.Get(engine.TypeHeader); len(engineType) > 0 {
		logMessage = append(logMessage, "engine_type", engineType)
	}

	if blockStoreType := r.Header.Get(querier.BlockStoreTypeHeader); len(blockStoreType) > 0 {
		logMessage = append(logMessage, "block_store_type", blockStoreType)
	}

	if acceptEncoding := r.Header.Get("Accept-Encoding"); len(acceptEncoding) > 0 {
		logMessage = append(logMessage, "accept_encoding", acceptEncoding)
	}

	shouldLog := source == requestmeta.SourceAPI || (f.cfg.EnabledRulerQueryStatsLog && source == requestmeta.SourceRuler)
	if shouldLog {
		logMessage = append(logMessage, formatQueryString(queryString)...)
		level.Info(util_log.WithContext(r.Context(), f.log)).Log(logMessage...)
	}
}

// reportSlowQuery reports slow queries.
func (f *Handler) reportSlowQuery(r *http.Request, queryString url.Values, queryResponseTime time.Duration) {