Fix: New request error handling.

This commit is contained in:
Mathieu Lecarme 2022-06-17 00:28:51 +02:00 committed by lperdereau
parent 24f67c0fe5
commit e57150ae1d

View file

@ -263,6 +263,10 @@ func (l *LokiSource) OneShotAcquisition(out chan types.Event, t *tomb.Tomb) erro
params.Encode())
logger := l.logger.WithField("url", url)
req, err := http.NewRequest("GET", url, nil)
if err != nil {
logger.WithError(err).Error("Loki NewRequest error")
return errors.Wrap(err, "Loki error while build new request")
}
req.Header = l.header
resp, err := http.DefaultClient.Do(req)