From acbd6ec37ca7cf5a18482cd585de810cc5eec75b Mon Sep 17 00:00:00 2001
From: Alan Bernstein <alan.aaron.bernstein@gmail.com>
Date: Thu, 10 Sep 2020 13:54:57 -0500
Subject: [PATCH] New channel per node

---
 http/handler.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/http/handler.go b/http/handler.go
index b6600b9f2..a0470139d 100644
--- a/http/handler.go
+++ b/http/handler.go
@@ -1632,10 +1632,10 @@ func (h *Handler) handleGetMetricsJSON(w http.ResponseWriter, r *http.Request) {
 	w.Header().Set("Content-Type", "application/json")
 
 	metrics := make(map[string][]*prom2json.Family)
-	mfChan := make(chan *dto.MetricFamily, 60)
 	transport := http.DefaultTransport.(*http.Transport).Clone()
 	for _, node := range h.api.Hosts(r.Context()) {
 		metricsURI := node.URI.String() + "/metrics"
+		mfChan := make(chan *dto.MetricFamily, 60)
 		err := prom2json.FetchMetricFamilies(metricsURI, mfChan, transport)
 		if err != nil {
 			http.Error(w, "fetching metrics: "+err.Error(), http.StatusInternalServerError)