|
12 | 12 | import org.elasticsearch.action.search.ClosePointInTimeRequest; |
13 | 13 | import org.elasticsearch.action.search.OpenPointInTimeRequest; |
14 | 14 | import org.elasticsearch.action.search.OpenPointInTimeResponse; |
| 15 | +import org.elasticsearch.action.search.SearchRequest; |
| 16 | +import org.elasticsearch.action.search.SearchShardsRequest; |
15 | 17 | import org.elasticsearch.action.search.SearchType; |
16 | 18 | import org.elasticsearch.action.search.TransportClosePointInTimeAction; |
17 | 19 | import org.elasticsearch.action.search.TransportOpenPointInTimeAction; |
| 20 | +import org.elasticsearch.action.search.TransportSearchShardsAction; |
18 | 21 | import org.elasticsearch.cluster.metadata.IndexMetadata; |
19 | 22 | import org.elasticsearch.common.bytes.BytesReference; |
20 | 23 | import org.elasticsearch.common.settings.Settings; |
@@ -158,6 +161,21 @@ public void testCanMatchSearch() { |
158 | 161 | assertNotMeasured(List.of(DFS_SEARCH_PHASE_METRIC, DFS_QUERY_SEARCH_PHASE_METRIC, OPEN_PIT_SEARCH_PHASE_METRIC)); |
159 | 162 | } |
160 | 163 |
|
| 164 | + public void testSearchShards() { |
| 165 | + var request = new SearchShardsRequest( |
| 166 | + new String[] { indexName }, |
| 167 | + SearchRequest.DEFAULT_INDICES_OPTIONS, |
| 168 | + simpleQueryStringQuery("doc1"), |
| 169 | + null, |
| 170 | + null, |
| 171 | + randomBoolean(), |
| 172 | + randomBoolean() ? null : randomAlphaOfLength(10) |
| 173 | + ); |
| 174 | + var resp = client().execute(TransportSearchShardsAction.TYPE, request).actionGet(); |
| 175 | + assertThat(resp.getGroups(), hasSize(num_primaries)); |
| 176 | + assertMeasurements(List.of(CAN_MATCH_SEARCH_PHASE_METRIC), 1); |
| 177 | + } |
| 178 | + |
161 | 179 | private void resetMeter() { |
162 | 180 | getTestTelemetryPlugin().resetMeter(); |
163 | 181 | } |
|
0 commit comments