diff options
author | 2017-08-06 05:54:24 -0700 | |
---|---|---|
committer | 2017-08-06 05:54:24 -0700 | |
commit | bcb2eb1ecc79b2721dc5a2e0cca64008b601e431 (patch) | |
tree | a2721b7dcf51dfac57f4e19d37d06ebc0c991973 /middleware/metrics/test/scrape.go | |
parent | 964f04f4433772795fd76711020c5616bad5b915 (diff) | |
download | coredns-bcb2eb1ecc79b2721dc5a2e0cca64008b601e431.tar.gz coredns-bcb2eb1ecc79b2721dc5a2e0cca64008b601e431.tar.zst coredns-bcb2eb1ecc79b2721dc5a2e0cca64008b601e431.zip |
all: gometalinter (#843)
* kubernetes/reverse: remove deadcode
* deadcode in errors and kubernetes removed
* unnecessary conversion
* constants
* proxy: time.Since()
* simplications
* static check
* Disable test/external_test
Diffstat (limited to 'middleware/metrics/test/scrape.go')
-rw-r--r-- | middleware/metrics/test/scrape.go | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/middleware/metrics/test/scrape.go b/middleware/metrics/test/scrape.go index c748be209..a21c0061d 100644 --- a/middleware/metrics/test/scrape.go +++ b/middleware/metrics/test/scrape.go @@ -69,7 +69,7 @@ type ( func Scrape(t *testing.T, url string) []*MetricFamily { mfChan := make(chan *dto.MetricFamily, 1024) - go fetchMetricFamilies(t, url, mfChan) + go fetchMetricFamilies(url, mfChan) result := []*MetricFamily{} for mf := range mfChan { @@ -177,20 +177,20 @@ func makeBuckets(m *dto.Metric) map[string]string { return result } -func fetchMetricFamilies(t *testing.T, url string, ch chan<- *dto.MetricFamily) { +func fetchMetricFamilies(url string, ch chan<- *dto.MetricFamily) { defer close(ch) req, err := http.NewRequest("GET", url, nil) if err != nil { - t.Fatalf("creating GET request for URL %q failed: %s", url, err) + return } req.Header.Add("Accept", acceptHeader) resp, err := http.DefaultClient.Do(req) if err != nil { - t.Fatalf("executing GET request for URL %q failed: %s", url, err) + return } defer resp.Body.Close() if resp.StatusCode != http.StatusOK { - t.Fatalf("GET request for URL %q returned HTTP status %s", url, resp.Status) + return } mediatype, params, err := mime.ParseMediaType(resp.Header.Get("Content-Type")) @@ -203,7 +203,7 @@ func fetchMetricFamilies(t *testing.T, url string, ch chan<- *dto.MetricFamily) if err == io.EOF { break } - t.Fatalf("reading metric family protocol buffer failed: %s", err) + return } ch <- mf } @@ -214,7 +214,7 @@ func fetchMetricFamilies(t *testing.T, url string, ch chan<- *dto.MetricFamily) var parser expfmt.TextParser metricFamilies, err := parser.TextToMetricFamilies(resp.Body) if err != nil { - t.Fatal("reading text format failed:", err) + return } for _, mf := range metricFamilies { ch <- mf |