|
22 | 22 | import org.elasticsearch.action.support.IndicesOptions; |
23 | 23 | import org.elasticsearch.common.settings.Settings; |
24 | 24 | import org.elasticsearch.common.settings.Settings.Builder; |
| 25 | +import org.elasticsearch.common.unit.TimeValue; |
25 | 26 | import org.elasticsearch.common.util.CollectionUtils; |
26 | 27 | import org.elasticsearch.test.AbstractStreamableTestCase; |
27 | 28 | import org.elasticsearch.test.ESTestCase; |
|
32 | 33 | import java.util.Locale; |
33 | 34 | import java.util.Set; |
34 | 35 | import java.util.StringJoiner; |
| 36 | +import java.util.function.Supplier; |
35 | 37 |
|
36 | 38 | public class UpdateSettingsRequestStreamableTests extends AbstractStreamableTestCase<UpdateSettingsRequest> { |
37 | 39 |
|
38 | 40 | @Override |
39 | 41 | protected UpdateSettingsRequest mutateInstance(UpdateSettingsRequest request) { |
40 | 42 | UpdateSettingsRequest mutation = copyRequest(request); |
41 | 43 | List<Runnable> mutators = new ArrayList<>(); |
| 44 | + Supplier<TimeValue> timeValueSupplier = () -> TimeValue.parseTimeValue(ESTestCase.randomTimeValue(), "_setting"); |
42 | 45 | mutators.add(() -> mutation |
43 | | - .masterNodeTimeout(randomValueOtherThan(request.masterNodeTimeout().getStringRep(), ESTestCase::randomTimeValue))); |
44 | | - mutators.add(() -> mutation.timeout(randomValueOtherThan(request.timeout().getStringRep(), ESTestCase::randomTimeValue))); |
| 46 | + .masterNodeTimeout(randomValueOtherThan(request.masterNodeTimeout(), timeValueSupplier))); |
| 47 | + mutators.add(() -> mutation.timeout(randomValueOtherThan(request.timeout(), timeValueSupplier))); |
45 | 48 | mutators.add(() -> mutation.settings(mutateSettings(request.settings()))); |
46 | 49 | mutators.add(() -> mutation.indices(mutateIndices(request.indices()))); |
47 | 50 | mutators.add(() -> mutation.indicesOptions(randomValueOtherThan(request.indicesOptions(), |
|
0 commit comments