(t *testing.T, method string, liveStore *e2e.HTTPService)
| 277 | } |
| 278 | |
| 279 | func preparePartitionDownscale(t *testing.T, method string, liveStore *e2e.HTTPService) preparePartitionDownscaleResponse { |
| 280 | req, err := http.NewRequest(method, "http://"+liveStore.Endpoint(3200)+"/live-store/prepare-partition-downscale", nil) |
| 281 | require.NoError(t, err) |
| 282 | httpResp, err := http.DefaultClient.Do(req) |
| 283 | require.NoError(t, err) |
| 284 | require.Equal(t, 200, httpResp.StatusCode) |
| 285 | |
| 286 | var result preparePartitionDownscaleResponse |
| 287 | require.NoError(t, json.NewDecoder(httpResp.Body).Decode(&result)) |
| 288 | return result |
| 289 | } |
| 290 | |
| 291 | func verifyPartitionState(t *testing.T, service *e2e.HTTPService, expectedState string, expectedCount int) { |
| 292 | partitionStateMatchers := []*labels.Matcher{ |
no test coverage detected