incl exemplars

ikethecoder · ikethecoder · commit 8610c242e4c8 · 2025-02-17T16:58:24.000-08:00
diff --git a/query-proxy/internal/app/query-proxy/reverse.go b/query-proxy/internal/app/query-proxy/reverse.go
@@ -62,15 +62,16 @@ func modifyRequest(r *http.Request, prometheusServerURL *url.URL, prometheusQuer
 }
 
 func checkRequest(r *http.Request, prometheusServerURL *url.URL, config *pkg.Specification) error {
-	if r.URL.Path == "/api/v1/query" || r.URL.Path == "/api/v1/query_range" {
+	if r.URL.Path == "/api/v1/query" || r.URL.Path == "/api/v1/query_range" || r.URL.Path == "/api/v1/query_exemplars" {
 		if err := modifyRequest(r, prometheusServerURL, "query", config); err != nil {
 			return err
 		}
-	}
-	if r.URL.Path == "/api/v1/series" || strings.HasPrefix(r.URL.Path, "/api/v1/label") {
+	} else if r.URL.Path == "/api/v1/series" || strings.HasPrefix(r.URL.Path, "/api/v1/label") {
 		if err := modifyRequest(r, prometheusServerURL, "match[]", config); err != nil {
 			return err
 		}
+	} else {
+		log.Println("WARN Passthrough", r.URL.Path)
 	}
 	r.Host = prometheusServerURL.Host
 	r.URL.Scheme = prometheusServerURL.Scheme

Original file line number	Diff line number	Diff line change
`@@ -62,15 +62,16 @@ func modifyRequest(r http.Request, prometheusServerURL url.URL, prometheusQuer`
`62`	`62`	`}`
`63`	`63`
`64`	`64`	`func checkRequest(r http.Request, prometheusServerURL url.URL, config *pkg.Specification) error {`
`65`		`- if r.URL.Path == "/api/v1/query" \|\| r.URL.Path == "/api/v1/query_range" {`
	`65`	`+ if r.URL.Path == "/api/v1/query" \|\| r.URL.Path == "/api/v1/query_range" \|\| r.URL.Path == "/api/v1/query_exemplars" {`
`66`	`66`	`if err := modifyRequest(r, prometheusServerURL, "query", config); err != nil {`
`67`	`67`	`return err`
`68`	`68`	`}`
`69`		`- }`
`70`		`- if r.URL.Path == "/api/v1/series" \|\| strings.HasPrefix(r.URL.Path, "/api/v1/label") {`
	`69`	`+ } else if r.URL.Path == "/api/v1/series" \|\| strings.HasPrefix(r.URL.Path, "/api/v1/label") {`
`71`	`70`	`if err := modifyRequest(r, prometheusServerURL, "match[]", config); err != nil {`
`72`	`71`	`return err`
`73`	`72`	`}`
	`73`	`+ } else {`
	`74`	`+ log.Println("WARN Passthrough", r.URL.Path)`
`74`	`75`	`}`
`75`	`76`	`r.Host = prometheusServerURL.Host`
`76`	`77`	`r.URL.Scheme = prometheusServerURL.Scheme`