diff --git a/prometheus/server/httphandler/query.go b/prometheus/server/httphandler/prometheusAPI.go similarity index 53% rename from prometheus/server/httphandler/query.go rename to prometheus/server/httphandler/prometheusAPI.go index d071d27ae2cb8b72c27f87ed0ea1f951e221e940..5fbd40b4adae2dff7662debb96479a6b2757d94b 100644 --- a/prometheus/server/httphandler/query.go +++ b/prometheus/server/httphandler/prometheusAPI.go @@ -41,3 +41,37 @@ func QueryRange(c *gin.Context) { c.Request.URL.Path = "api/v1/query_range" //请求API proxy.ServeHTTP(c.Writer, c.Request) } + +func Targets(c *gin.Context) { + remote := c.GetString("targets") + if remote == "" { + fmt.Println("get reverse dest failed!") + return + } + url, err := url.Parse(remote) + if err != nil { + return + } + + proxy := httputil.NewSingleHostReverseProxy(url) + + c.Request.URL.Path = "api/v1/targets" //请求API + proxy.ServeHTTP(c.Writer, c.Request) +} + +func Alerts(c *gin.Context) { + remote := c.GetString("alerts") + if remote == "" { + fmt.Println("get reverse dest failed!") + return + } + url, err := url.Parse(remote) + if err != nil { + return + } + + proxy := httputil.NewSingleHostReverseProxy(url) + + c.Request.URL.Path = "api/v1/alerts" //请求API + proxy.ServeHTTP(c.Writer, c.Request) +} diff --git a/prometheus/server/httphandler/target.go b/prometheus/server/httphandler/target.go index 98b20bcac0c19556058d839827e73c38318ffd0a..e1d804ffc1527a9e662ce6f70ea1a4e2f9d0315e 100644 --- a/prometheus/server/httphandler/target.go +++ b/prometheus/server/httphandler/target.go @@ -1,10 +1,7 @@ package httphandler import ( - "fmt" "net/http" - "net/http/httputil" - "net/url" "gitee.com/openeuler/PilotGo-plugins/sdk/response" "github.com/gin-gonic/gin" @@ -26,23 +23,6 @@ func DBTargets(c *gin.Context) { c.JSON(http.StatusOK, objs) } -func PrometheusAPITargets(c *gin.Context) { - remote := c.GetString("targets") - if remote == "" { - fmt.Println("get reverse dest failed!") - return - } - url, err := url.Parse(remote) - if err != nil { - return - } - - proxy := httputil.NewSingleHostReverseProxy(url) - - c.Request.URL.Path = "api/v1/targets" //请求API - proxy.ServeHTTP(c.Writer, c.Request) -} - type PrometheusObject struct { Targets []string `json:"targets"` } diff --git a/prometheus/server/router/router.go b/prometheus/server/router/router.go index d23851dd65f0f65b7007fc87a3ff81a63f692a47..5adbbde016d350847ffffaa294b59a0fc3aa65d2 100644 --- a/prometheus/server/router/router.go +++ b/prometheus/server/router/router.go @@ -38,7 +38,11 @@ func RegisterAPIs(router *gin.Engine) { }) prometheus.GET("/targets", func(c *gin.Context) { c.Set("targets", global.GlobalClient.PluginInfo.ReverseDest) - httphandler.PrometheusAPITargets(c) + httphandler.Targets(c) + }) + prometheus.GET("/alerts", func(c *gin.Context) { + c.Set("alerts", global.GlobalClient.PluginInfo.ReverseDest) + httphandler.Alerts(c) }) }