Skip to content

Commit

Permalink
Addressed review comments
Browse files Browse the repository at this point in the history
Signed-off-by: Marco Pracucci <[email protected]>
  • Loading branch information
pracucci committed Jun 17, 2024
1 parent ac30faf commit ad9d997
Show file tree
Hide file tree
Showing 2 changed files with 12 additions and 11 deletions.
21 changes: 11 additions & 10 deletions pkg/frontend/querymiddleware/remote_read_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@ func TestParseRemoteReadRequestWithoutConsumingBody(t *testing.T) {
},
"valid body": {
makeRequest: func() *http.Request {
return generateTestRemoteReadHTTPRequest(generateTestRemoteReadRequest())
return makeTestHTTPRequestFromRemoteRead(makeTestRemoteReadRequest())
},
expectedParams: url.Values{
"start_0": []string{"0"},
Expand Down Expand Up @@ -136,7 +136,7 @@ func TestRemoteReadRoundTripperCallsDownstreamOnAll(t *testing.T) {
return tc.handler
})
rr := newRemoteReadRoundTripper(roundTripper, middleware)
_, err := rr.RoundTrip(generateTestRemoteReadHTTPRequest(generateTestRemoteReadRequest()))
_, err := rr.RoundTrip(makeTestHTTPRequestFromRemoteRead(makeTestRemoteReadRequest()))
if tc.expectError != "" {
require.Error(t, err)
require.Equal(t, tc.expectError, err.Error())
Expand Down Expand Up @@ -172,7 +172,7 @@ func TestRemoteReadRoundTripper_ShouldAllowMiddlewaresToManipulateRequest(t *tes
expectedEndMs = 2
)

origRemoteReadReq := generateTestRemoteReadRequest()
origRemoteReadReq := makeTestRemoteReadRequest()

// Create a middleware that manipulate the query start/end timestamps.
middleware := MetricsQueryMiddlewareFunc(func(next MetricsQueryHandler) MetricsQueryHandler {
Expand All @@ -191,7 +191,7 @@ func TestRemoteReadRoundTripper_ShouldAllowMiddlewaresToManipulateRequest(t *tes
}

rr := newRemoteReadRoundTripper(downstream, middleware)
_, err := rr.RoundTrip(generateTestRemoteReadHTTPRequest(origRemoteReadReq))
_, err := rr.RoundTrip(makeTestHTTPRequestFromRemoteRead(origRemoteReadReq))
require.NoError(t, err)
require.NotNil(t, downstreamReq)

Expand All @@ -206,13 +206,13 @@ func TestRemoteReadRoundTripper_ShouldAllowMiddlewaresToManipulateRequest(t *tes

// Ensure the downstream received the manipulated start/end timestamps.
for i, query := range downstreamRemoteReadReq.Queries {
require.Equal(t, int64(1), query.StartTimestampMs)
require.Equal(t, int64(2), query.EndTimestampMs)
require.Equal(t, int64(expectedStartMs), query.StartTimestampMs)
require.Equal(t, int64(expectedEndMs), query.EndTimestampMs)

if origRemoteReadReq.Queries[i].Hints != nil {
require.NotNil(t, query.Hints)
require.Equal(t, int64(1), query.Hints.StartMs)
require.Equal(t, int64(2), query.Hints.EndMs)
require.Equal(t, int64(expectedStartMs), query.Hints.StartMs)
require.Equal(t, int64(expectedEndMs), query.Hints.EndMs)
}
}

Expand Down Expand Up @@ -324,7 +324,7 @@ func TestRemoteReadQueryRequest_WithStartEnd(t *testing.T) {
}
}

func generateTestRemoteReadHTTPRequest(readReq *prompb.ReadRequest) *http.Request {
func makeTestHTTPRequestFromRemoteRead(readReq *prompb.ReadRequest) *http.Request {
request := httptest.NewRequest("GET", "/api/v1/read", nil)
request.Header.Add("User-Agent", "test-user-agent")
request.Header.Add("Content-Type", "application/x-protobuf")
Expand All @@ -336,7 +336,7 @@ func generateTestRemoteReadHTTPRequest(readReq *prompb.ReadRequest) *http.Reques
return request
}

func generateTestRemoteReadRequest() *prompb.ReadRequest {
func makeTestRemoteReadRequest() *prompb.ReadRequest {
return &prompb.ReadRequest{
Queries: []*prompb.Query{
{
Expand All @@ -346,6 +346,7 @@ func generateTestRemoteReadRequest() *prompb.ReadRequest {
},
StartTimestampMs: 0,
EndTimestampMs: 42,
Hints: nil, // Don't add hints to this query so that we exercise code when the request query has no hints.
},
{
Matchers: []*prompb.LabelMatcher{
Expand Down
2 changes: 1 addition & 1 deletion pkg/frontend/querymiddleware/roundtrip_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -610,7 +610,7 @@ func TestRemoteReadMiddleware(t *testing.T) {
}{
"valid query": {
makeRequest: func() *http.Request {
return generateTestRemoteReadHTTPRequest(generateTestRemoteReadRequest())
return makeTestHTTPRequestFromRemoteRead(makeTestRemoteReadRequest())
},
limits: mockLimits{},
},
Expand Down

0 comments on commit ad9d997

Please sign in to comment.