Review feedback, fix distributor concurrency handling

Author: juliusv

cmd/distributor/main.go

@@ -48,7 +48,6 @@ func main() {
 	if err != nil {
 		log.Fatalf("Error initializing distributor: %v", err)
 	}
-	go dist.Run()
 	defer dist.Stop()
 
 	server := server.New(serverConfig, r)

cmd/querier/main.go

@@ -42,6 +42,7 @@ func main() {
 	if err != nil {
 		log.Fatalf("Error initializing distributor: %v", err)
 	}
+	defer dist.Stop()
 
 	server := server.New(serverConfig, r)
 	defer server.Stop()

cmd/ruler/main.go

@@ -36,6 +36,7 @@ func main() {
 	if err != nil {
 		log.Fatalf("Error initializing distributor: %v", err)
 	}
+	defer dist.Stop()
 
 	rulerServer, err := ruler.NewServer(rulerConfig, ruler.NewRuler(rulerConfig, dist, chunkStore))
 	if err != nil {

distributor/distributor.go

@@ -141,6 +141,7 @@ func New(cfg Config, ring ReadRing) (*Distributor, error) {
 		}, []string{"ingester"}),
 	}
 	prometheus.MustRegister(d)
+	go d.Run()
 	return d, nil
 }