Skip to content

Commit dbfd088

Browse files
committed
Add tests
1 parent 4e0df7a commit dbfd088

File tree

2 files changed

+11
-1
lines changed

2 files changed

+11
-1
lines changed

server/src/test/java/org/elasticsearch/cluster/metadata/DataStreamLifecycleTemplateTests.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -226,6 +226,7 @@ public static DataStreamLifecycle.Template randomDataLifecycleTemplate() {
226226
? randomBoolean() ? ResettableValue.undefined() : ResettableValue.reset()
227227
: randomDownsamplingMethod()
228228
)
229+
.frozenAfter(randomFrozenAfter())
229230
.buildTemplate();
230231
}
231232

@@ -295,7 +296,7 @@ private static ResettableValue<TimeValue> randomFrozenAfter() {
295296
return switch (randomIntBetween(0, 2)) {
296297
case 0 -> ResettableValue.undefined();
297298
case 1 -> ResettableValue.reset();
298-
case 2 -> ResettableValue.create(TimeValue.timeValueDays(randomIntBetween(1, 100)));
299+
case 2 -> ResettableValue.create(randomPositiveTimeValue());
299300
default -> throw new IllegalStateException("Unknown randomisation path");
300301
};
301302
}

server/src/test/java/org/elasticsearch/cluster/metadata/DataStreamLifecycleTests.java

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -493,6 +493,15 @@ public void testEffectiveRetention() {
493493
}
494494
}
495495

496+
public void testNegativeFrozenAfter() {
497+
final var frozenAfter = randomBoolean() ? TimeValue.ZERO : TimeValue.MINUS_ONE;
498+
IllegalArgumentException exception = expectThrows(
499+
IllegalArgumentException.class,
500+
() -> DataStreamLifecycle.dataLifecycleBuilder().frozenAfter(frozenAfter).build()
501+
);
502+
assertThat(exception.getMessage(), equalTo("frozen_after must be a positive time value"));
503+
}
504+
496505
public void testEffectiveRetentionParams() {
497506
Map<String, String> initialParams = randomMap(0, 10, () -> Tuple.tuple(randomAlphaOfLength(10), randomAlphaOfLength(10)));
498507
ToXContent.Params params = DataStreamLifecycle.addEffectiveRetentionParams(new ToXContent.MapParams(initialParams));

0 commit comments

Comments
 (0)