DefaultChunkedReadLimit was moved from storage to config

Signed-off-by: György Krajcsovits <gyorgy.krajcsovits@grafana.com>

Author: krajorama

integration/e2emimir/client.go

@@ -28,6 +28,7 @@ import (
 	promapi "github.com/prometheus/client_golang/api"
 	promv1 "github.com/prometheus/client_golang/api/prometheus/v1"
 	"github.com/prometheus/common/model"
+	promConfig "github.com/prometheus/prometheus/config"
 	"github.com/prometheus/prometheus/model/rulefmt"
 	"github.com/prometheus/prometheus/prompb" // OTLP protos are not compatible with gogo
 	"github.com/prometheus/prometheus/storage/remote"
@@ -351,7 +352,7 @@ func parseRemoteReadSamples(resp *http.Response) (*prompb.QueryResult, error) {
 }
 
 func parseRemoteReadChunks(resp *http.Response) ([]prompb.ChunkedReadResponse, error) {
-	stream := remote.NewChunkedReader(resp.Body, remote.DefaultChunkedReadLimit, nil)
+	stream := remote.NewChunkedReader(resp.Body, promConfig.DefaultChunkedReadLimit, nil)
 
 	var results []prompb.ChunkedReadResponse
 	for {

pkg/querier/remote_read_test.go

@@ -19,6 +19,7 @@ import (
 	"github.com/golang/snappy"
 	"github.com/pkg/errors"
 	"github.com/prometheus/common/model"
+	"github.com/prometheus/prometheus/config"
 	"github.com/prometheus/prometheus/model/labels"
 	"github.com/prometheus/prometheus/prompb"
 	"github.com/prometheus/prometheus/promql"
@@ -453,7 +454,7 @@ func TestRemoteReadHandler_StreamedXORChunks(t *testing.T) {
 					require.Equal(t, 200, recorder.Result().StatusCode)
 					require.Equal(t, []string{api.ContentTypeRemoteReadStreamedChunks}, recorder.Result().Header["Content-Type"])
 
-					stream := prom_remote.NewChunkedReader(recorder.Result().Body, prom_remote.DefaultChunkedReadLimit, nil)
+					stream := prom_remote.NewChunkedReader(recorder.Result().Body, config.DefaultChunkedReadLimit, nil)
 
 					i := 0
 					for {