diff --git a/merger/merge.go b/merger/merge.go index 41cd668..bf2dc86 100644 --- a/merger/merge.go +++ b/merger/merge.go @@ -7,7 +7,6 @@ import ( "sort" "sync" - "github.com/pkg/errors" prom "github.com/prometheus/client_model/go" "github.com/prometheus/common/expfmt" "golang.org/x/sync/errgroup" @@ -24,13 +23,19 @@ func (m *merger) merge(ctx context.Context, w io.Writer) error { g.Go(func() error { resp, err := m.client.Get(source.url) if err != nil { - return errors.Wrap(err, fmt.Sprintf("get url: %s", source.url)) + fmt.Printf("get url: %s", source.url) + return nil } - defer resp.Body.Close() + defer func(Body io.ReadCloser) { + err := Body.Close() + if err != nil { + } + }(resp.Body) tp := new(expfmt.TextParser) out, err := tp.TextToMetricFamilies(resp.Body) if err != nil { - return errors.Wrap(err, fmt.Sprintf("parse url: %s", source.url)) + fmt.Printf("parse url: %s", source.url) + return nil } mu.Lock() defer mu.Unlock()