limits: add tenant to log lines for per-stream rate-limited and out-of-order errors (#8177)

pkg/ingester/stream.go

@@ -235,7 +235,7 @@ func errorForFailedEntries(s *stream, failedEntriesWithError []entryWithError, t
 			entryWithError.entry.Timestamp.String(), entryWithError.e.Error(), streamName)
 	}
 
-	fmt.Fprintf(&buf, "total ignored: %d out of %d", len(failedEntriesWithError), totalEntries)
+	fmt.Fprintf(&buf, "user '%s', total ignored: %d out of %d", s.tenant, len(failedEntriesWithError), totalEntries)
 
 	return httpgrpc.Errorf(statusCode, buf.String())
 }

pkg/ingester/stream_test.go

@@ -84,7 +84,7 @@ func TestMaxReturnedStreamsErrors(t *testing.T) {
 				)
 			}
 
-			fmt.Fprintf(&expected, "total ignored: %d out of %d", numLogs, numLogs)
+			fmt.Fprintf(&expected, "user 'fake', total ignored: %d out of %d", numLogs, numLogs)
 			expectErr := httpgrpc.Errorf(http.StatusBadRequest, expected.String())
 
 			_, err = s.Push(context.Background(), newLines, recordPool.GetRecord(), 0, true, false)