Skip to content
Merged
Changes from 1 commit
Commits
Show all changes
42 commits
Select commit Hold shift + click to select a range
b1d4793
replace json data conversion with protobuf for querier handler
afhassan Jun 29, 2023
c54f8f5
add stats to PrometheusResponse created from query data
afhassan Jul 12, 2023
cabd489
add conversion from query data to PrometheusInstantQueryResponse in q…
afhassan Jul 12, 2023
b843075
remove endpoints not used by query api and add it as a handler for /q…
afhassan Jul 13, 2023
f1eddd9
add snappy compression
afhassan Jul 13, 2023
855375f
improve code readability in querier handler
afhassan Jul 14, 2023
6884a45
add Query and QueryRange handler functions directly to router
afhassan Jul 18, 2023
f83b731
add scalar and string result types to instant query handler
afhassan Jul 21, 2023
112312b
reuse time parsing functions for querier handler
afhassan Jul 28, 2023
9717483
improve querier handler code readability
afhassan Jul 28, 2023
581847a
reuse thanos api struct definitions for querier handler
afhassan Aug 2, 2023
a6e8e04
return json response for unsharded querier requests
afhassan Aug 9, 2023
45c85a7
remove header copying in codec for querier handler
afhassan Aug 9, 2023
7af52db
change instant query context cancelled unit test to test new querier …
afhassan Aug 21, 2023
ad7e03c
handle empty response errors
afhassan Aug 14, 2023
5d7ada2
add config to specify compression type for querier handler response
afhassan Aug 16, 2023
661b078
change unit tests to work with new querier handler
afhassan Aug 21, 2023
78b12ab
fix time parsing in querier handler
afhassan Aug 23, 2023
a55d23a
add unit tests for querier handler
afhassan Aug 23, 2023
3d35da3
add feature flag for querier handler
afhassan Aug 24, 2023
9f77e36
refactor querier unit tests
afhassan Aug 6, 2024
17f325c
Merge branch 'cortexproject:master' into master
afhassan Aug 6, 2024
1c7397e
add protobuf codec to reuse prometheus handler for querier
afhassan Aug 9, 2024
8c4dafe
Merge remote-tracking branch 'upstream/master'
afhassan Sep 4, 2024
a466d86
refactor to use unified protobuf struct for both range and instant qu…
afhassan Sep 11, 2024
018c931
fix issue with sample pointers
afhassan Sep 11, 2024
dea9806
Merge remote-tracking branch 'upstream/master'
afhassan Sep 13, 2024
0afa97d
fix protobuf tests to expect peakSamples
afhassan Sep 13, 2024
4da5cb0
refactor protobuf config logic
afhassan Sep 17, 2024
a917d28
refactor protobuf codec
afhassan Sep 17, 2024
2f1b315
add config validation
afhassan Sep 18, 2024
6a457e7
remove snappy compression tests
afhassan Sep 18, 2024
7898191
fix linter formatting
afhassan Sep 18, 2024
9b6ef8c
fix protobuf empty slice decoding
afhassan Sep 19, 2024
4901a28
add integration test for protobuf codec
afhassan Sep 20, 2024
0a7d807
add gzip compression to integration test
afhassan Sep 23, 2024
8c9eaf0
Merge remote-tracking branch 'upstream/master'
afhassan Sep 24, 2024
0f6e8bd
fix recompile proto files
afhassan Sep 24, 2024
7730ad2
update config docs
afhassan Sep 24, 2024
5d8658e
add changelog for protobuf codec
afhassan Sep 24, 2024
91e1366
make gzip default compression
afhassan Sep 25, 2024
390e370
add protobuf codec to experimental features
afhassan Sep 25, 2024
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
19 changes: 19 additions & 0 deletions integration/query_frontend_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -203,6 +203,25 @@ func TestQueryFrontendWithVerticalShardingQueryScheduler(t *testing.T) {
})
}

func TestQueryFrontendProtobufCodec(t *testing.T) {
runQueryFrontendTest(t, queryFrontendTestConfig{
testMissingMetricName: false,
querySchedulerEnabled: true,
queryStatsEnabled: true,
setup: func(t *testing.T, s *e2e.Scenario) (configFile string, flags map[string]string) {
require.NoError(t, writeFileToSharedDir(s, cortexConfigFile, []byte(BlocksStorageConfig)))

minio := e2edb.NewMinio(9000, BlocksStorageFlags()["-blocks-storage.s3.bucket-name"])
require.NoError(t, s.StartAndWaitReady(minio))

flags = mergeFlags(e2e.EmptyFlags(), map[string]string{
"-api.querier-default-codec": "protobuf",
})
return cortexConfigFile, flags
},
})
}

func TestQueryFrontendRemoteRead(t *testing.T) {
runQueryFrontendTest(t, queryFrontendTestConfig{
remoteReadEnabled: true,
Expand Down