Skip to content

Commit 297f568

Browse files
committed
Use builder for failure store template to minimise the change the diff when adding failures lifecycle
1 parent 723a581 commit 297f568

File tree

5 files changed

+28
-23
lines changed

5 files changed

+28
-23
lines changed

modules/data-streams/src/internalClusterTest/java/org/elasticsearch/datastreams/SystemDataStreamIT.java

Lines changed: 17 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -401,17 +401,23 @@ public Collection<SystemDataStreamDescriptor> getSystemDataStreamDescriptors() {
401401
Type.EXTERNAL,
402402
ComposableIndexTemplate.builder()
403403
.indexPatterns(List.of(".test-failure-store"))
404-
.template(Template.builder().mappings(new CompressedXContent("""
405-
{
406-
"properties": {
407-
"@timestamp" : {
408-
"type": "date"
409-
},
410-
"count": {
411-
"type": "long"
412-
}
413-
}
414-
}""")).dataStreamOptions(new DataStreamOptions.Template(new DataStreamFailureStore.Template(true))))
404+
.template(
405+
Template.builder()
406+
.mappings(new CompressedXContent("""
407+
{
408+
"properties": {
409+
"@timestamp" : {
410+
"type": "date"
411+
},
412+
"count": {
413+
"type": "long"
414+
}
415+
}
416+
}"""))
417+
.dataStreamOptions(
418+
new DataStreamOptions.Template(DataStreamFailureStore.builder().enabled(true).buildTemplate())
419+
)
420+
)
415421
.dataStreamTemplate(new ComposableIndexTemplate.DataStreamTemplate())
416422
.build(),
417423
Map.of(),

modules/data-streams/src/internalClusterTest/java/org/elasticsearch/datastreams/lifecycle/ExplainDataStreamLifecycleIT.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -265,7 +265,7 @@ public void testExplainFailuresLifecycle() throws Exception {
265265
null,
266266
null,
267267
DataStreamLifecycle.Template.DATA_DEFAULT,
268-
new DataStreamOptions.Template(new DataStreamFailureStore.Template(true))
268+
new DataStreamOptions.Template(DataStreamFailureStore.builder().enabled(true).buildTemplate())
269269
);
270270
String dataStreamName = "metrics-foo";
271271
CreateDataStreamAction.Request createDataStreamRequest = new CreateDataStreamAction.Request(
@@ -400,7 +400,7 @@ public void testExplainLifecycleForIndicesWithErrors() throws Exception {
400400
null,
401401
null,
402402
lifecycle,
403-
new DataStreamOptions.Template(new DataStreamFailureStore.Template(true))
403+
new DataStreamOptions.Template(DataStreamFailureStore.builder().enabled(true).buildTemplate())
404404
);
405405
String dataStreamName = "metrics-foo";
406406
CreateDataStreamAction.Request createDataStreamRequest = new CreateDataStreamAction.Request(

modules/data-streams/src/test/java/org/elasticsearch/datastreams/DataStreamsStatsTests.java

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,6 @@
2727
import org.elasticsearch.cluster.metadata.ComposableIndexTemplate;
2828
import org.elasticsearch.cluster.metadata.DataStreamFailureStore;
2929
import org.elasticsearch.cluster.metadata.DataStreamOptions;
30-
import org.elasticsearch.cluster.metadata.ResettableValue;
3130
import org.elasticsearch.cluster.metadata.Template;
3231
import org.elasticsearch.common.compress.CompressedXContent;
3332
import org.elasticsearch.index.mapper.extras.MapperExtrasPlugin;
@@ -271,11 +270,9 @@ private String createDataStream() throws Exception {
271270

272271
private String createDataStream(boolean hidden, boolean failureStore) throws Exception {
273272
String dataStreamName = randomAlphaOfLength(10).toLowerCase(Locale.getDefault());
274-
ResettableValue<DataStreamOptions.Template> failureStoreOptions = failureStore == false
275-
? ResettableValue.undefined()
276-
: ResettableValue.create(
277-
new DataStreamOptions.Template(ResettableValue.create(new DataStreamFailureStore.Template(ResettableValue.create(true))))
278-
);
273+
DataStreamOptions.Template failureStoreOptions = failureStore == false
274+
? null
275+
: new DataStreamOptions.Template(DataStreamFailureStore.builder().enabled(true).buildTemplate());
279276
Template idxTemplate = new Template(null, new CompressedXContent("""
280277
{"properties":{"@timestamp":{"type":"date"},"data":{"type":"keyword"}}}
281278
"""), null, null, failureStoreOptions);

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

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -273,7 +273,7 @@ public void testXContentSerializationWithRolloverAndEffectiveRetention() throws
273273
Settings settings = null;
274274
CompressedXContent mappings = null;
275275
Map<String, AliasMetadata> aliases = null;
276-
ResettableValue<DataStreamOptions.Template> dataStreamOptions = ResettableValue.undefined();
276+
DataStreamOptions.Template dataStreamOptions = null;
277277
if (randomBoolean()) {
278278
settings = randomSettings();
279279
}
@@ -284,7 +284,8 @@ public void testXContentSerializationWithRolloverAndEffectiveRetention() throws
284284
aliases = randomAliases();
285285
}
286286
if (randomBoolean()) {
287-
dataStreamOptions = randomDataStreamOptionsTemplate();
287+
// Do not set random lifecycle to avoid having data_retention and effective_retention in the response.
288+
dataStreamOptions = new DataStreamOptions.Template(DataStreamFailureStore.builder().enabled(randomBoolean()).buildTemplate());
288289
}
289290
DataStreamLifecycle.Template lifecycle = DataStreamLifecycle.Template.DATA_DEFAULT;
290291
ComponentTemplate template = new ComponentTemplate(

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

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -223,7 +223,7 @@ public void testXContentSerializationWithRolloverAndEffectiveRetention() throws
223223
Settings settings = null;
224224
CompressedXContent mappings = null;
225225
Map<String, AliasMetadata> aliases = null;
226-
ResettableValue<DataStreamOptions.Template> dataStreamOptions = ResettableValue.undefined();
226+
DataStreamOptions.Template dataStreamOptions = null;
227227
ComposableIndexTemplate.DataStreamTemplate dataStreamTemplate = randomDataStreamTemplate();
228228
if (randomBoolean()) {
229229
settings = randomSettings();
@@ -235,7 +235,8 @@ public void testXContentSerializationWithRolloverAndEffectiveRetention() throws
235235
aliases = randomAliases();
236236
}
237237
if (randomBoolean()) {
238-
dataStreamOptions = ComponentTemplateTests.randomDataStreamOptionsTemplate();
238+
// Do not set random lifecycle to avoid having data_retention and effective_retention in the response.
239+
dataStreamOptions = new DataStreamOptions.Template(DataStreamFailureStore.builder().enabled(randomBoolean()).buildTemplate());
239240
}
240241
// We use the empty lifecycle so the global retention can be in effect
241242
DataStreamLifecycle.Template lifecycle = DataStreamLifecycle.Template.DATA_DEFAULT;

0 commit comments

Comments
 (0)