diff --git a/etcdmain/grpc_proxy.go b/etcdmain/grpc_proxy.go index 4cc7910e1642..9aa2523883bb 100644 --- a/etcdmain/grpc_proxy.go +++ b/etcdmain/grpc_proxy.go @@ -148,7 +148,7 @@ func startGRPCProxy(cmd *cobra.Command, args []string) { client := mustNewClient() - srvhttp, httpl := mustHTTPListener(m, tlsinfo) + srvhttp, httpl := mustHTTPListener(m, tlsinfo, client) errc := make(chan error) go func() { errc <- newGRPCProxyServer(client).Serve(grpcl) }() go func() { errc <- srvhttp.Serve(httpl) }() @@ -157,7 +157,7 @@ func startGRPCProxy(cmd *cobra.Command, args []string) { mhttpl := mustMetricsListener(tlsinfo) go func() { mux := http.NewServeMux() - etcdhttp.HandlePrometheus(mux) + etcdhttp.HandleMetricsHealth(mux, client) plog.Fatal(http.Serve(mhttpl, mux)) }() } @@ -290,10 +290,10 @@ func newGRPCProxyServer(client *clientv3.Client) *grpc.Server { return server } -func mustHTTPListener(m cmux.CMux, tlsinfo *transport.TLSInfo) (*http.Server, net.Listener) { +func mustHTTPListener(m cmux.CMux, tlsinfo *transport.TLSInfo, cli *clientv3.Client) (*http.Server, net.Listener) { httpmux := http.NewServeMux() httpmux.HandleFunc("/", http.NotFound) - etcdhttp.HandlePrometheus(httpmux) + etcdhttp.HandleMetricsHealth(httpmux, cli) if grpcProxyEnablePprof { for p, h := range debugutil.PProfHandlers() { httpmux.Handle(p, h)