fix: updated retry/error messages with clearer detail

runner/sidecar/in.go

@@ -68,10 +68,10 @@ func connectIn(ctx context.Context, sink func(context.Context, []byte) error) (f
 			inFlight.Inc()
 			defer inFlight.Dec()
 			if _, err := fifo.Write(data); err != nil {
-				return fmt.Errorf("failed to send to main: %w", err)
+				return fmt.Errorf("failed to write to fifo: %w", err)
 			}
 			if _, err := fifo.Write([]byte("\n")); err != nil {
-				return fmt.Errorf("failed to send to main: %w", err)
+				return fmt.Errorf("failed to write to fifo: %w", err)
 			}
 			return nil
 		}, nil
@@ -103,12 +103,12 @@ func connectIn(ctx context.Context, sink func(context.Context, []byte) error) (f
 				return err
 			}
 			if resp, err := httpClient.Do(req); err != nil {
-				return fmt.Errorf("failed to send to main: %w", err)
+				return fmt.Errorf("failed to execute HTTP request: %w", err)
 			} else {
 				body, _ := ioutil.ReadAll(resp.Body)
 				_ = resp.Body.Close()
 				if resp.StatusCode >= 300 {
-					return fmt.Errorf("failed to send to main: %q %q", resp.Status, body)
+					return fmt.Errorf("HTTP request failed: %q %q", resp.Status, body)
 				}
 				if resp.StatusCode == 201 {
 					return sink(ctx, body)

runner/sidecar/sources.go

@@ -105,8 +105,9 @@ func connectSources(ctx context.Context, process func(context.Context, []byte) e
 					if err == nil {
 						return nil
 					}
-					logger.Error(err, "⚠ →", "source", sourceName, "backoffSteps", backoff.Steps)
-					if backoff.Steps <= 0 {
+					giveUp := backoff.Steps <= 0
+					logger.Error(err, "failed to send process message", "source", sourceName, "backoffSteps", backoff.Steps, "giveUp", giveUp)
+					if giveUp {
 						errorsCounter.WithLabelValues(sourceName, fmt.Sprint(replica)).Inc()
 						return err
 					}