(t *testing.T, service *e2e.HTTPService)
| 264 | } |
| 265 | |
| 266 | func getRingStatus(t *testing.T, service *e2e.HTTPService) ringStatus { |
| 267 | req, err := http.NewRequest("GET", "http://"+service.Endpoint(3200)+"/partition-ring", nil) |
| 268 | req.Header.Set("Accept", "application/json") |
| 269 | require.NoError(t, err) |
| 270 | httpResp, err := http.DefaultClient.Do(req) |
| 271 | require.NoError(t, err) |
| 272 | require.Equal(t, 200, httpResp.StatusCode) |
| 273 | |
| 274 | var result ringStatus |
| 275 | require.NoError(t, json.NewDecoder(httpResp.Body).Decode(&result)) |
| 276 | return result |
| 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) |
no test coverage detected