diff --git a/backend/prome/prome.go b/backend/prome/prome.go index 19d8ba22..73f72c31 100644 --- a/backend/prome/prome.go +++ b/backend/prome/prome.go @@ -225,20 +225,21 @@ func (pd *PromeDataSource) processWrite(payload []byte) { for _, c := range pd.WriteTargets { newC := c go func(cc *HttpClient, payload []byte) { - sendOk := false var err error + var rec bool for i := 0; i < retry; i++ { - err := remoteWritePost(cc, payload) + err = remoteWritePost(cc, payload) if err == nil { sendOk = true break } - err, ok := err.(RecoverableError) - if !ok { + err, rec = err.(RecoverableError) + if !rec { break } + logger.Warningf("send prome fail: %v", err) time.Sleep(time.Millisecond * 100) }