integration: Enable the parquet row ranges cache in the single-binary querier

Assert that the cache misses on the first query and hits when querying the
same stored series again.

Signed-off-by: Siddarth Gundu <siddarthg0910@gmail.com>

Author: siddarth2810

integration/querier_test.go

@@ -36,6 +36,7 @@ func TestQuerierWithBlocksStorageRunningInSingleBinaryMode(t *testing.T) {
 		blocksShardingEnabled bool
 		indexCacheBackend     string
 		parquetLabelsCache    string
+		parquetRowRangesCache string
 	}{
 		// tsdb bucket storage
 		"[TSDB] blocks sharding enabled, memcached index cache, bucket index enabled": {
@@ -49,15 +50,17 @@ func TestQuerierWithBlocksStorageRunningInSingleBinaryMode(t *testing.T) {
 			indexCacheBackend:     tsdb.IndexCacheBackendRedis,
 		},
 		// parquet bucket storage
-		"[Parquet] blocks sharding enabled, memcached parquet labels cache, bucket index enabled": {
+		"[Parquet] blocks sharding enabled, memcached parquet cache, bucket index enabled": {
 			bucketStorageType:     "parquet",
 			blocksShardingEnabled: true,
 			parquetLabelsCache:    tsdb.CacheBackendMemcached,
+			parquetRowRangesCache: tsdb.CacheBackendMemcached,
 		},
-		"[Parquet] blocks sharding enabled, redis parquet labels cache, bucket index enabled": {
+		"[Parquet] blocks sharding enabled, redis parquet cache, bucket index enabled": {
 			bucketStorageType:     "parquet",
 			blocksShardingEnabled: true,
 			parquetLabelsCache:    tsdb.CacheBackendRedis,
+			parquetRowRangesCache: tsdb.CacheBackendMemcached,
 		},
 	}
 
@@ -131,6 +134,7 @@ func TestQuerierWithBlocksStorageRunningInSingleBinaryMode(t *testing.T) {
 					flags["-parquet-converter.conversion-interval"] = "1s"
 					flags["-parquet-converter.ring.consul.hostname"] = consul.NetworkHTTPEndpoint()
 					flags["-blocks-storage.bucket-store.parquet-labels-cache.backend"] = testCfg.parquetLabelsCache
+					flags["-blocks-storage.bucket-store.parquet-row-ranges-cache.backend"] = testCfg.parquetRowRangesCache
 					flags["-compactor.block-ranges"] = "1ms,12h"
 				}
 
@@ -150,6 +154,14 @@ func TestQuerierWithBlocksStorageRunningInSingleBinaryMode(t *testing.T) {
 					flags["-blocks-storage.bucket-store.parquet-labels-cache.redis.addresses"] = redis.NetworkEndpoint(e2ecache.RedisPort)
 				}
 
+				// Add the parquet row ranges cache address
+				if strings.Contains(testCfg.parquetRowRangesCache, tsdb.CacheBackendMemcached) {
+					flags["-blocks-storage.bucket-store.parquet-row-ranges-cache.memcached.addresses"] = "dns+" + memcached.NetworkEndpoint(e2ecache.MemcachedPort)
+				}
+				if strings.Contains(testCfg.parquetRowRangesCache, tsdb.CacheBackendRedis) {
+					flags["-blocks-storage.bucket-store.parquet-row-ranges-cache.redis.addresses"] = redis.NetworkEndpoint(e2ecache.RedisPort)
+				}
+
 				// Start Cortex replicas.
 				cortex1 := e2ecortex.NewSingleBinary("cortex-1", flags, "")
 				cortex2 := e2ecortex.NewSingleBinary("cortex-2", flags, "")
@@ -253,6 +265,10 @@ func TestQuerierWithBlocksStorageRunningInSingleBinaryMode(t *testing.T) {
 					require.NoError(t, cluster.WaitSumMetrics(e2e.Equals(0), "thanos_store_index_cache_hits_total"))                                            // no cache hit cause the cache was empty
 				}
 
+				if testCfg.bucketStorageType == "parquet" {
+					require.NoError(t, cluster.WaitSumMetricsWithOptions(e2e.Greater(0), []string{"cortex_parquet_row_ranges_cache_misses_total"}, e2e.WaitMissingMetrics))
+				}
+
 				if testCfg.indexCacheBackend == tsdb.IndexCacheBackendMemcached {
 					require.NoError(t, cluster.WaitSumMetrics(e2e.Equals(float64(21*seriesReplicationFactor)), "thanos_memcached_operations_total")) // 14 gets + 7 sets
 				}
@@ -268,6 +284,7 @@ func TestQuerierWithBlocksStorageRunningInSingleBinaryMode(t *testing.T) {
 					require.NoError(t, cluster.WaitSumMetrics(e2e.Equals(float64((12+2)*seriesReplicationFactor)), "thanos_store_index_cache_requests_total"))
 					require.NoError(t, cluster.WaitSumMetrics(e2e.Equals(float64(2*seriesReplicationFactor)), "thanos_store_index_cache_hits_total")) // this time has used the index cache
 				case "parquet":
+					require.NoError(t, cluster.WaitSumMetricsWithOptions(e2e.Greater(0), []string{"cortex_parquet_row_ranges_cache_hits_total"}, e2e.WaitMissingMetrics))
 					switch testCfg.parquetLabelsCache {
 					case tsdb.CacheBackendInMemory:
 						require.NoError(t, cluster.WaitSumMetrics(e2e.Greater(float64(0)), "thanos_cache_inmemory_requests_total"))