Chore: use strconv.ParseInt() with 32bit when parsing 32bit numbers (#…

…10201)

* Chore: use strconv.ParseInt() with 32bit when parsing ingester ID

Signed-off-by: Marco Pracucci <marco@pracucci.com>

* Address parsing in NewMetadataHandler()

Signed-off-by: Marco Pracucci <marco@pracucci.com>

* Fix linter issue

Signed-off-by: Marco Pracucci <marco@pracucci.com>

* Remove noop casting

Signed-off-by: Marco Pracucci <marco@pracucci.com>

---------

Signed-off-by: Marco Pracucci <marco@pracucci.com>

pkg/querier/metadata_handler.go

@@ -48,28 +48,34 @@ type metadataErrorResult struct {
 // Mimir for a given tenant. It is kept and returned as a set.
 func NewMetadataHandler(m MetadataSupplier) http.Handler {
 	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
-		limit := -1
+		limit := int32(-1)
 		if s := r.FormValue("limit"); s != "" {
-			var err error
-			if limit, err = strconv.Atoi(s); err != nil {
+			parsed, err := strconv.ParseInt(s, 10, 32)
+			if err != nil {
 				w.WriteHeader(http.StatusBadRequest)
 				util.WriteJSONResponse(w, metadataErrorResult{Status: statusError, Error: "limit must be a number"})
 				return
 			}
+
+			limit = int32(parsed)
 		}
-		limitPerMetric := -1
+
+		limitPerMetric := int32(-1)
 		if s := r.FormValue("limit_per_metric"); s != "" {
-			var err error
-			if limitPerMetric, err = strconv.Atoi(s); err != nil {
+			parsed, err := strconv.ParseInt(s, 10, 32)
+			if err != nil {
 				w.WriteHeader(http.StatusBadRequest)
 				util.WriteJSONResponse(w, metadataErrorResult{Status: statusError, Error: "limit_per_metric must be a number"})
 				return
 			}
+
+			limitPerMetric = int32(parsed)
 		}
+
 		metric := r.FormValue("metric")
 		req := &client.MetricsMetadataRequest{
-			Limit:          int32(limit),
-			LimitPerMetric: int32(limitPerMetric),
+			Limit:          limit,
+			LimitPerMetric: limitPerMetric,
 			Metric:         metric,
 		}
 
@@ -87,11 +93,11 @@ func NewMetadataHandler(m MetadataSupplier) http.Handler {
 			// We enforce this both here and in the ingesters. Doing it in the ingesters is
 			// more efficient as it is earlier in the process, but since that one is per user,
 			// we still need to do it here after all the results are merged.
-			if limitPerMetric > 0 && len(ms) >= limitPerMetric {
+			if limitPerMetric > 0 && len(ms) >= int(limitPerMetric) {
 				continue
 			}
 			if !ok {
-				if limit >= 0 && len(metrics) >= limit {
+				if limit >= 0 && len(metrics) >= int(limit) {
 					break
 				}
 				// Most metrics will only hold 1 copy of the same metadata.

pkg/storage/ingest/util.go

@@ -36,7 +36,7 @@ func IngesterPartitionID(ingesterID string) (int32, error) {
 	}
 
 	// Parse the ingester sequence number.
-	ingesterSeq, err := strconv.Atoi(match[1])
+	ingesterSeq, err := strconv.ParseInt(match[1], 10, 32)
 	if err != nil {
 		return 0, fmt.Errorf("no ingester sequence number in ingester ID %s", ingesterID)
 	}