Fix: Improve log levels for max queue size and channel not found (#12)

Closes #6
fortio · Oct 22, 2023 · da87622 · da87622
1 parent 85c6a35
commit da87622
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/app.go b/app.go
@@ -211,7 +211,7 @@ func (app *App) processQueue(ctx context.Context, maxRetries int, initialBackoff
 					retryable, pause, description := CheckError(err.Error(), msg.Channel)
 
 					if pause {
-						log.S(log.Info, "Channel not found, pausing for 15 minutes", log.String("channel", msg.Channel))
+						log.S(log.Warning, "Channel not found, pausing for 15 minutes", log.String("channel", msg.Channel))
 						app.metrics.RequestsNotProcessed.WithLabelValues(msg.Channel).Inc()
 						break
 					}

diff --git a/server.go b/server.go
@@ -57,7 +57,7 @@ func (app *App) handleRequest(w http.ResponseWriter, r *http.Request) {
 	// Ideally we don't reject at 90%, but initially after some tests I got blocked. So I decided to be a bit more conservative.
 	// ToDo: Fix this behavior so we can reach 100% channel size without problems.
 	if len(app.slackQueue) >= maxQueueSize {
-		log.S(log.Info, "Queue is almost full, returning StatusServiceUnavailable", log.Int("queueSize", len(app.slackQueue)))
+		log.S(log.Warning, "Queue is almost full, returning StatusServiceUnavailable", log.Int("queueSize", len(app.slackQueue)))
 
 		err := jrpc.Reply[SlackResponse](w, http.StatusServiceUnavailable, &SlackResponse{
 			Ok:    false,