update

cmd/thanos/receive.go

@@ -5,7 +5,6 @@ package main
 
 import (
 	"context"
-	"net/http"
 	"os"
 	"path"
 	"strings"
@@ -312,6 +311,7 @@ func runReceive(
 			httpserver.WithGracePeriod(time.Duration(*conf.httpGracePeriod)),
 			httpserver.WithTLSConfig(*conf.httpTLSConfig),
 		)
+		httpserver.RegisterDownscale(srv, dbs.GetTenants())
 		g.Add(func() error {
 			statusProber.Healthy()
 			return srv.ListenAndServe()
@@ -323,12 +323,6 @@ func runReceive(
 		})
 	}
 
-	level.Debug(logger).Log("msg", "setting up downscale HTTP server")
-	{
-		http.HandleFunc("/downscale", func(w http.ResponseWriter, r *http.Request) { w.WriteHeader(http.StatusOK) })
-		http.ListenAndServe(":8080", nil)
-	}
-
 	level.Debug(logger).Log("msg", "setting up gRPC server")
 	{
 		tlsCfg, err := tls.NewServerConfig(log.With(logger, "protocol", "gRPC"), conf.grpcConfig.tlsSrvCert, conf.grpcConfig.tlsSrvKey, conf.grpcConfig.tlsSrvClientCA)

pkg/receive/multitsdb.go

@@ -106,6 +106,10 @@ func (t *MultiTSDB) SkipMatchExternalLabels() {
 	t.skipMatchExternalLabels = true
 }
 
+func (t *MultiTSDB) GetTenants() map[string]*tenant {
+	return t.tenants
+}
+
 type localClient struct {
 	store *store.TSDBStore
 }

pkg/server/http/http.go

@@ -5,6 +5,7 @@ package http
 
 import (
 	"context"
+	"fmt"
 	"net/http"
 	"net/http/pprof"
 
@@ -68,6 +69,13 @@ func New(logger log.Logger, reg *prometheus.Registry, comp component.Component,
 	}
 }
 
+func RegisterDownscale[K comparable, V any](s *Server, m map[K]V) {
+	s.mux.Handle("/-/downscale", http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		w.WriteHeader(http.StatusOK)
+		fmt.Fprintln(w, len(m))
+	}))
+}
+
 // ListenAndServe listens on the TCP network address and handles requests on incoming connections.
 func (s *Server) ListenAndServe() error {
 	level.Info(s.logger).Log("msg", "listening for requests and metrics", "address", s.opts.listen)