From e437bc6deed6b843a6d1d50bf27d7d83b9b7567b Mon Sep 17 00:00:00 2001 From: Lou Knauer Date: Thu, 2 Jun 2022 12:15:08 +0200 Subject: [PATCH] fix error handling --- sinks/httpSink.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/sinks/httpSink.go b/sinks/httpSink.go index c0a99ce..466915d 100644 --- a/sinks/httpSink.go +++ b/sinks/httpSink.go @@ -97,13 +97,17 @@ func (s *HttpSink) Flush() error { if err != nil { cclog.ComponentError(s.name, "transport/tcp error:", err.Error()) // Wait between retries - time.Sleep(time.Duration(i+1) * time.Second) + time.Sleep(time.Duration(i+1) * (time.Second / 2)) continue } break } + if res == nil { + return errors.New("flush failed due to repeated errors") + } + // Handle application errors if res.StatusCode != http.StatusOK { err := errors.New(res.Status)