Remove GetHeaders from logproto.VolumeResponse.

pkg/logproto/compat.go

@@ -323,7 +323,3 @@ func (m *VolumeRequest) LogToSpan(sp opentracing.Span) {
 		otlog.String("end", timestamp.Time(int64(m.Through)).String()),
 	)
 }
-
-func (*VolumeResponse) GetHeaders() []*definitions.PrometheusResponseHeader {
-	return nil
-}

pkg/querier/handler.go

@@ -94,7 +94,11 @@ func (h *Handler) Do(ctx context.Context, req queryrangebase.Request) (queryrang
 		}
 		return &queryrange.IndexStatsResponse{Response: result}, nil
 	case *logproto.VolumeRequest:
-		return h.api.VolumeHandler(ctx, concrete)
+		result, err := h.api.VolumeHandler(ctx, concrete)
+		if err != nil {
+			return nil, err
+		}
+		return &queryrange.VolumeResponse{Response: result}, nil
 	default:
 		return nil, fmt.Errorf("unsupported query type %T", req)
 	}

pkg/querier/queryrange/codec.go

@@ -1535,7 +1535,7 @@ func NewEmptyResponse(r queryrangebase.Request) (queryrangebase.Response, error)
 	case *logproto.IndexStatsRequest:
 		return &logproto.IndexStatsResponse{}, nil
 	case *logproto.VolumeRequest:
-		return &logproto.VolumeResponse{}, nil
+		return &VolumeResponse{}, nil
 	default:
 		return nil, fmt.Errorf("unsupported request type %T", req)
 	}

pkg/querier/queryrange/limits_test.go

@@ -280,7 +280,7 @@ func Test_MaxQueryLookBack_Types(t *testing.T) {
 				From:    model.Time(now.UnixMilli()),
 				Through: model.Time(now.Add(-90 * time.Minute).UnixMilli()),
 			},
-			expectedResponse: &logproto.VolumeResponse{},
+			expectedResponse: &VolumeResponse{},
 		},
 	}