mirror of
https://github.com/VictoriaMetrics/VictoriaMetrics.git
synced 2024-11-21 14:44:00 +00:00
feat(httpserver): add http.externalUrl
config to http server, it adds prefix to http path automatically (#452)
This commit is contained in:
parent
09f5d0056f
commit
34743974d5
1 changed files with 12 additions and 0 deletions
|
@ -27,6 +27,7 @@ var (
|
||||||
tlsCertFile = flag.String("tlsCertFile", "", "Path to file with TLS certificate. Used only if -tls is set. Prefer ECDSA certs instead of RSA certs, since RSA certs are slow")
|
tlsCertFile = flag.String("tlsCertFile", "", "Path to file with TLS certificate. Used only if -tls is set. Prefer ECDSA certs instead of RSA certs, since RSA certs are slow")
|
||||||
tlsKeyFile = flag.String("tlsKeyFile", "", "Path to file with TLS key. Used only if -tls is set")
|
tlsKeyFile = flag.String("tlsKeyFile", "", "Path to file with TLS key. Used only if -tls is set")
|
||||||
|
|
||||||
|
httpExternalURL = flag.String("http.externalURL", "", "The URL under which the http service is externally reachable")
|
||||||
httpAuthUsername = flag.String("httpAuth.username", "", "Username for HTTP Basic Auth. The authentication is disabled if empty. See also -httpAuth.password")
|
httpAuthUsername = flag.String("httpAuth.username", "", "Username for HTTP Basic Auth. The authentication is disabled if empty. See also -httpAuth.password")
|
||||||
httpAuthPassword = flag.String("httpAuth.password", "", "Password for HTTP Basic Auth. The authentication is disabled if -httpAuth.username is empty")
|
httpAuthPassword = flag.String("httpAuth.password", "", "Password for HTTP Basic Auth. The authentication is disabled if -httpAuth.username is empty")
|
||||||
metricsAuthKey = flag.String("metricsAuthKey", "", "Auth key for /metrics. It overrides httpAuth settings")
|
metricsAuthKey = flag.String("metricsAuthKey", "", "Auth key for /metrics. It overrides httpAuth settings")
|
||||||
|
@ -62,6 +63,15 @@ func Serve(addr string, rh RequestHandler) {
|
||||||
if *tlsEnable {
|
if *tlsEnable {
|
||||||
scheme = "https"
|
scheme = "https"
|
||||||
}
|
}
|
||||||
|
// parse and format `httpExternalURL` to /<defined_string>` ,
|
||||||
|
if *httpExternalURL != "" {
|
||||||
|
if !strings.HasPrefix(*httpExternalURL, "/") {
|
||||||
|
*httpExternalURL = "/" + *httpExternalURL
|
||||||
|
}
|
||||||
|
if strings.HasSuffix(*httpExternalURL, "/") {
|
||||||
|
*httpExternalURL = strings.TrimRight(*httpExternalURL, "/")
|
||||||
|
}
|
||||||
|
}
|
||||||
logger.Infof("starting http server at %s://%s/", scheme, addr)
|
logger.Infof("starting http server at %s://%s/", scheme, addr)
|
||||||
logger.Infof("pprof handlers are exposed at %s://%s/debug/pprof/", scheme, addr)
|
logger.Infof("pprof handlers are exposed at %s://%s/debug/pprof/", scheme, addr)
|
||||||
lnTmp, err := netutil.NewTCPListener(scheme, addr)
|
lnTmp, err := netutil.NewTCPListener(scheme, addr)
|
||||||
|
@ -157,6 +167,8 @@ var metricsHandlerDuration = metrics.NewHistogram(`vm_http_request_duration_seco
|
||||||
|
|
||||||
func handlerWrapper(w http.ResponseWriter, r *http.Request, rh RequestHandler) {
|
func handlerWrapper(w http.ResponseWriter, r *http.Request, rh RequestHandler) {
|
||||||
requestsTotal.Inc()
|
requestsTotal.Inc()
|
||||||
|
// delete extra url string, extra is a string formated as `/<defined_string>` when server start up
|
||||||
|
r.URL.Path = strings.Replace(r.URL.Path, *httpExternalURL, "", 1)
|
||||||
switch r.URL.Path {
|
switch r.URL.Path {
|
||||||
case "/health":
|
case "/health":
|
||||||
w.Header().Set("Content-Type", "text/plain")
|
w.Header().Set("Content-Type", "text/plain")
|
||||||
|
|
Loading…
Reference in a new issue