log error case when server returns with 429

cloudradar-monitoring · Sep 15, 2020 · 39b4113 · 39b4113
1 parent 580afa0
commit 39b4113
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/handler.go b/handler.go
@@ -78,6 +78,7 @@ func (ca *Cagent) Run(outputFile *os.File, interrupt chan struct{}) {
 			if err == ErrHubTooManyRequests {
 				// for error code 429, wait 10 seconds and try again
 				retryIn = 10 * time.Second
+				log.Errorf("Run: hub is overloaded, retrying in %v", retryIn)
 			} else if err == ErrHubServerError {
 				// for error codes 5xx, wait for configured amount of time and try again
 				retryIn = time.Duration(ca.Config.OnHTTP5xxRetryInterval) * time.Second
@@ -312,6 +313,7 @@ func (ca *Cagent) RunHeartbeat(interrupt chan struct{}) {
 			if err == ErrHubTooManyRequests {
 				// for error code 429, wait 10 seconds and try again
 				retryIn = 10 * time.Second
+				log.Errorf("RunHeartbeat: hub is overloaded, retrying in %v", retryIn)
 			} else if err == ErrHubServerError {
 				// for error codes 5xx, wait for configured amount of time and try again
 				retryIn = time.Duration(ca.Config.OnHTTP5xxRetryInterval) * time.Second

diff --git a/pkg/csender/hub.go b/pkg/csender/hub.go
@@ -60,6 +60,7 @@ func (cs *Csender) GracefulSend() error {
 		if err == cagent.ErrHubTooManyRequests {
 			// for error code 429, wait 10 seconds and try again
 			retryIn = 10 * time.Second
+			log.Errorf("csender: hub is overloaded, retrying in %v", retryIn)
 		} else if err == cagent.ErrHubServerError {
 			// for error codes 5xx, wait for 2 seconds and try again
 			retryIn = retryInterval