fix: correcting the condition for switching to cold storages (#301)

eguguchkin · web-flow · commit 727a5b3ba1f0 · 2025-12-25T17:18:54.000+03:00
diff --git a/storeapi/grpc_search.go b/storeapi/grpc_search.go
@@ -83,7 +83,7 @@ func (g *GrpcV1) doSearch(
 
 	// in store mode hot we return error in case request wants data, that we've already rotated
 	if g.config.StoreMode == StoreModeHot {
-		if g.fracManager.Flags().IsCapacityExceeded() && g.earlierThanOldestFrac(uint64(from)) {
+		if g.fracManager.Flags().IsCapacityExceeded() && g.earlierThanOldestFrac(uint64(req.From)) {
 			metric.RejectedRequests.WithLabelValues("search", "old_data").Inc()
 			return &storeapi.SearchResponse{Code: storeapi.SearchErrorCode_INGESTOR_QUERY_WANTS_OLD_DATA}, nil
 		}

Original file line number	Diff line number	Diff line change
`@@ -83,7 +83,7 @@ func (g *GrpcV1) doSearch(`
`83`	`83`
`84`	`84`	`// in store mode hot we return error in case request wants data, that we've already rotated`
`85`	`85`	`if g.config.StoreMode == StoreModeHot {`
`86`		`- if g.fracManager.Flags().IsCapacityExceeded() && g.earlierThanOldestFrac(uint64(from)) {`
	`86`	`+ if g.fracManager.Flags().IsCapacityExceeded() && g.earlierThanOldestFrac(uint64(req.From)) {`
`87`	`87`	`metric.RejectedRequests.WithLabelValues("search", "old_data").Inc()`
`88`	`88`	`return &storeapi.SearchResponse{Code: storeapi.SearchErrorCode_INGESTOR_QUERY_WANTS_OLD_DATA}, nil`
`89`	`89`	`}`