diff --git a/modules/data-streams/src/internalClusterTest/java/org/elasticsearch/datastreams/lifecycle/DataStreamLifecycleServiceIT.java b/modules/data-streams/src/internalClusterTest/java/org/elasticsearch/datastreams/lifecycle/DataStreamLifecycleServiceIT.java index 0802846721691..6890fbc21975a 100644 --- a/modules/data-streams/src/internalClusterTest/java/org/elasticsearch/datastreams/lifecycle/DataStreamLifecycleServiceIT.java +++ b/modules/data-streams/src/internalClusterTest/java/org/elasticsearch/datastreams/lifecycle/DataStreamLifecycleServiceIT.java @@ -146,7 +146,7 @@ public void cleanup() { public void testRolloverLifecycle() throws Exception { // empty lifecycle contains the default rollover - DataStreamLifecycle.Template lifecycle = DataStreamLifecycle.Template.DEFAULT; + DataStreamLifecycle.Template lifecycle = DataStreamLifecycle.Template.DATA_DEFAULT; putComposableIndexTemplate("id1", null, List.of("metrics-foo*"), null, null, lifecycle, false); String dataStreamName = "metrics-foo"; @@ -353,7 +353,7 @@ public void testOriginationDate() throws Exception { } public void testUpdatingLifecycleAppliesToAllBackingIndices() throws Exception { - DataStreamLifecycle.Template lifecycle = DataStreamLifecycle.Template.DEFAULT; + DataStreamLifecycle.Template lifecycle = DataStreamLifecycle.Template.DATA_DEFAULT; putComposableIndexTemplate("id1", null, List.of("metrics-foo*"), null, null, lifecycle, false); @@ -384,7 +384,7 @@ public void testAutomaticForceMerge() throws Exception { * because all necessary merging has already happened automatically. So in order to detect whether forcemerge has been called, we * use a SendRequestBehavior in the MockTransportService to detect it. */ - DataStreamLifecycle.Template lifecycle = DataStreamLifecycle.Template.DEFAULT; + DataStreamLifecycle.Template lifecycle = DataStreamLifecycle.Template.DATA_DEFAULT; disableDataStreamLifecycle(); String dataStreamName = "metrics-foo"; putComposableIndexTemplate( @@ -477,7 +477,7 @@ private static void disableDataStreamLifecycle() { public void testErrorRecordingOnRollover() throws Exception { // empty lifecycle contains the default rollover - DataStreamLifecycle.Template lifecycle = DataStreamLifecycle.Template.DEFAULT; + DataStreamLifecycle.Template lifecycle = DataStreamLifecycle.Template.DATA_DEFAULT; /* * We set index.auto_expand_replicas to 0-1 so that if we get a single-node cluster it is not yellow. The cluster being yellow * could result in data stream lifecycle's automatic forcemerge failing, which would result in an unexpected error in the error @@ -613,7 +613,7 @@ public void testErrorRecordingOnRollover() throws Exception { public void testErrorRecordingOnRetention() throws Exception { // starting with a lifecycle without retention so we can rollover the data stream and manipulate the second generation index such // that its retention execution fails - DataStreamLifecycle.Template lifecycle = DataStreamLifecycle.Template.DEFAULT; + DataStreamLifecycle.Template lifecycle = DataStreamLifecycle.Template.DATA_DEFAULT; /* * We set index.auto_expand_replicas to 0-1 so that if we get a single-node cluster it is not yellow. The cluster being yellow @@ -750,7 +750,7 @@ public void testErrorRecordingOnRetention() throws Exception { } public void testDataLifecycleServiceConfiguresTheMergePolicy() throws Exception { - DataStreamLifecycle.Template lifecycle = DataStreamLifecycle.Template.DEFAULT; + DataStreamLifecycle.Template lifecycle = DataStreamLifecycle.Template.DATA_DEFAULT; putComposableIndexTemplate( "id1", diff --git a/modules/data-streams/src/internalClusterTest/java/org/elasticsearch/datastreams/lifecycle/ExplainDataStreamLifecycleIT.java b/modules/data-streams/src/internalClusterTest/java/org/elasticsearch/datastreams/lifecycle/ExplainDataStreamLifecycleIT.java index a92d5ac98f148..7f5fd14fd45d6 100644 --- a/modules/data-streams/src/internalClusterTest/java/org/elasticsearch/datastreams/lifecycle/ExplainDataStreamLifecycleIT.java +++ b/modules/data-streams/src/internalClusterTest/java/org/elasticsearch/datastreams/lifecycle/ExplainDataStreamLifecycleIT.java @@ -92,7 +92,7 @@ public void cleanup() { public void testExplainLifecycle() throws Exception { // empty lifecycle contains the default rollover - DataStreamLifecycle.Template lifecycle = DataStreamLifecycle.Template.DEFAULT; + DataStreamLifecycle.Template lifecycle = DataStreamLifecycle.Template.DATA_DEFAULT; putComposableIndexTemplate("id1", null, List.of("metrics-foo*"), null, null, lifecycle); String dataStreamName = "metrics-foo"; @@ -264,7 +264,7 @@ public void testExplainFailuresLifecycle() throws Exception { List.of("metrics-foo*"), null, null, - DataStreamLifecycle.Template.DEFAULT, + DataStreamLifecycle.Template.DATA_DEFAULT, new DataStreamOptions.Template(new DataStreamFailureStore.Template(true)) ); String dataStreamName = "metrics-foo"; @@ -381,7 +381,7 @@ public void testExplainFailuresLifecycle() throws Exception { public void testExplainLifecycleForIndicesWithErrors() throws Exception { // empty lifecycle contains the default rollover - DataStreamLifecycle.Template lifecycle = DataStreamLifecycle.Template.DEFAULT; + DataStreamLifecycle.Template lifecycle = DataStreamLifecycle.Template.DATA_DEFAULT; putComposableIndexTemplate( "id1", diff --git a/modules/data-streams/src/test/java/org/elasticsearch/datastreams/MetadataIndexTemplateServiceTests.java b/modules/data-streams/src/test/java/org/elasticsearch/datastreams/MetadataIndexTemplateServiceTests.java index 835cff8a081fa..a7414b8a231c4 100644 --- a/modules/data-streams/src/test/java/org/elasticsearch/datastreams/MetadataIndexTemplateServiceTests.java +++ b/modules/data-streams/src/test/java/org/elasticsearch/datastreams/MetadataIndexTemplateServiceTests.java @@ -156,7 +156,7 @@ public void testLifecycleComposition() { // Enabled is always true unless it's explicitly set to false { DataStreamLifecycle.Template lifecycle = new DataStreamLifecycle.Template(false, randomPositiveTimeValue(), randomRounds()); - List lifecycles = List.of(lifecycle, DataStreamLifecycle.Template.DEFAULT); + List lifecycles = List.of(lifecycle, DataStreamLifecycle.Template.DATA_DEFAULT); DataStreamLifecycle result = composeDataLifecycles(lifecycles).build(); assertThat(result.enabled(), equalTo(true)); assertThat(result.dataRetention(), equalTo(lifecycle.dataRetention().get())); diff --git a/modules/data-streams/src/test/java/org/elasticsearch/datastreams/action/GetDataStreamsResponseTests.java b/modules/data-streams/src/test/java/org/elasticsearch/datastreams/action/GetDataStreamsResponseTests.java index 6741cc808ebed..f4ed40b2e0078 100644 --- a/modules/data-streams/src/test/java/org/elasticsearch/datastreams/action/GetDataStreamsResponseTests.java +++ b/modules/data-streams/src/test/java/org/elasticsearch/datastreams/action/GetDataStreamsResponseTests.java @@ -53,7 +53,7 @@ public void testResponseIlmAndDataStreamLifecycleRepresentation() throws Excepti .setGeneration(3) .setAllowCustomRouting(true) .setIndexMode(IndexMode.STANDARD) - .setLifecycle(new DataStreamLifecycle()) + .setLifecycle(DataStreamLifecycle.DEFAULT_DATA_LIFECYCLE) .setDataStreamOptions(DataStreamOptions.FAILURE_STORE_ENABLED) .setFailureIndices(DataStream.DataStreamIndices.failureIndicesBuilder(failureStores).build()) .build(); diff --git a/modules/data-streams/src/test/java/org/elasticsearch/datastreams/lifecycle/DataStreamLifecycleServiceTests.java b/modules/data-streams/src/test/java/org/elasticsearch/datastreams/lifecycle/DataStreamLifecycleServiceTests.java index e4abd9980019e..37301fbf403a8 100644 --- a/modules/data-streams/src/test/java/org/elasticsearch/datastreams/lifecycle/DataStreamLifecycleServiceTests.java +++ b/modules/data-streams/src/test/java/org/elasticsearch/datastreams/lifecycle/DataStreamLifecycleServiceTests.java @@ -247,7 +247,7 @@ public void testRetentionNotConfigured() { dataStreamName, numBackingIndices, settings(IndexVersion.current()), - new DataStreamLifecycle(), + DataStreamLifecycle.DEFAULT_DATA_LIFECYCLE, now ); builder.put(dataStream); @@ -496,7 +496,7 @@ public void testDeletedIndicesAreRemovedFromTheErrorStore() throws IOException { dataStreamName, numBackingIndices, Settings.builder().put(IndexMetadata.SETTING_VERSION_CREATED, IndexVersion.current()), - new DataStreamLifecycle(), + DataStreamLifecycle.DEFAULT_DATA_LIFECYCLE, now ); builder.put(dataStream); @@ -1482,7 +1482,7 @@ public void testTargetIndices() { numBackingIndices, numFailureIndices, settings(IndexVersion.current()), - new DataStreamLifecycle(), + DataStreamLifecycle.DEFAULT_DATA_LIFECYCLE, now ).copy().setDataStreamOptions(dataStreamOptions).build(); // failure store is managed even when disabled builder.put(dataStream); diff --git a/server/src/main/java/org/elasticsearch/action/admin/indices/template/post/TransportSimulateIndexTemplateAction.java b/server/src/main/java/org/elasticsearch/action/admin/indices/template/post/TransportSimulateIndexTemplateAction.java index 81fceefc93830..25018bb32bf3b 100644 --- a/server/src/main/java/org/elasticsearch/action/admin/indices/template/post/TransportSimulateIndexTemplateAction.java +++ b/server/src/main/java/org/elasticsearch/action/admin/indices/template/post/TransportSimulateIndexTemplateAction.java @@ -348,7 +348,7 @@ public static Template resolveTemplate( DataStreamLifecycle.Builder lifecycleBuilder = resolveLifecycle(simulatedProject, matchingTemplate); DataStreamLifecycle.Template lifecycle = lifecycleBuilder == null ? null : lifecycleBuilder.buildTemplate(); if (template.getDataStreamTemplate() != null && lifecycle == null && isDslOnlyMode) { - lifecycle = DataStreamLifecycle.Template.DEFAULT; + lifecycle = DataStreamLifecycle.Template.DATA_DEFAULT; } DataStreamOptions.Builder optionsBuilder = resolveDataStreamOptions(simulatedProject, matchingTemplate); return new Template( diff --git a/server/src/main/java/org/elasticsearch/cluster/metadata/DataStreamLifecycle.java b/server/src/main/java/org/elasticsearch/cluster/metadata/DataStreamLifecycle.java index 1b2d2acd0e04c..fdae853292457 100644 --- a/server/src/main/java/org/elasticsearch/cluster/metadata/DataStreamLifecycle.java +++ b/server/src/main/java/org/elasticsearch/cluster/metadata/DataStreamLifecycle.java @@ -86,7 +86,7 @@ public static boolean isDataStreamsLifecycleOnlyMode(final Settings settings) { Setting.Property.NodeScope ); - public static final DataStreamLifecycle DEFAULT = new DataStreamLifecycle(); + public static final DataStreamLifecycle DEFAULT_DATA_LIFECYCLE = new DataStreamLifecycle(null, null, null); public static final String DATA_STREAM_LIFECYCLE_ORIGIN = "data_stream_lifecycle"; @@ -132,10 +132,6 @@ public static boolean isDataStreamsLifecycleOnlyMode(final Settings settings) { @Nullable private final List downsampling; - public DataStreamLifecycle() { - this(null, null, null); - } - public DataStreamLifecycle( @Nullable Boolean enabled, @Nullable TimeValue dataRetention, @@ -566,7 +562,7 @@ public Template(boolean enabled, TimeValue dataRetention, List aliases = null; - DataStreamLifecycle.Template lifecycle = DataStreamLifecycle.Template.DEFAULT; + DataStreamLifecycle.Template lifecycle = DataStreamLifecycle.Template.DATA_DEFAULT; ResettableValue dataStreamOptions = ResettableValue.undefined(); if (randomBoolean()) { settings = randomSettings(); diff --git a/server/src/test/java/org/elasticsearch/action/datastreams/lifecycle/ExplainDataStreamLifecycleResponseTests.java b/server/src/test/java/org/elasticsearch/action/datastreams/lifecycle/ExplainDataStreamLifecycleResponseTests.java index fb3cefe3751b2..762aff6e3c4e0 100644 --- a/server/src/test/java/org/elasticsearch/action/datastreams/lifecycle/ExplainDataStreamLifecycleResponseTests.java +++ b/server/src/test/java/org/elasticsearch/action/datastreams/lifecycle/ExplainDataStreamLifecycleResponseTests.java @@ -63,7 +63,7 @@ protected NamedWriteableRegistry getNamedWriteableRegistry() { @SuppressWarnings("unchecked") public void testToXContent() throws IOException { long now = System.currentTimeMillis(); - DataStreamLifecycle lifecycle = new DataStreamLifecycle(); + DataStreamLifecycle lifecycle = DataStreamLifecycle.DEFAULT_DATA_LIFECYCLE; ExplainIndexDataStreamLifecycle explainIndex = createRandomIndexDataStreamLifecycleExplanation(now, lifecycle); explainIndex.setNowSupplier(() -> now); { @@ -241,7 +241,7 @@ public void testToXContent() throws IOException { public void testChunkCount() { long now = System.currentTimeMillis(); - DataStreamLifecycle lifecycle = new DataStreamLifecycle(); + DataStreamLifecycle lifecycle = DataStreamLifecycle.DEFAULT_DATA_LIFECYCLE; Response response = new Response( List.of( createRandomIndexDataStreamLifecycleExplanation(now, lifecycle), @@ -298,7 +298,12 @@ protected Response mutateInstance(Response instance) { private Response randomResponse() { return new Response( - List.of(createRandomIndexDataStreamLifecycleExplanation(System.nanoTime(), randomBoolean() ? new DataStreamLifecycle() : null)), + List.of( + createRandomIndexDataStreamLifecycleExplanation( + System.nanoTime(), + randomBoolean() ? DataStreamLifecycle.DEFAULT_DATA_LIFECYCLE : null + ) + ), randomBoolean() ? new RolloverConfiguration( new RolloverConditions( diff --git a/server/src/test/java/org/elasticsearch/action/datastreams/lifecycle/ExplainIndexDataStreamLifecycleTests.java b/server/src/test/java/org/elasticsearch/action/datastreams/lifecycle/ExplainIndexDataStreamLifecycleTests.java index cec0fdad15f01..7691f20b727c2 100644 --- a/server/src/test/java/org/elasticsearch/action/datastreams/lifecycle/ExplainIndexDataStreamLifecycleTests.java +++ b/server/src/test/java/org/elasticsearch/action/datastreams/lifecycle/ExplainIndexDataStreamLifecycleTests.java @@ -41,7 +41,7 @@ public void testGetGenerationTime() { now, randomBoolean() ? now + TimeValue.timeValueDays(1).getMillis() : null, null, - new DataStreamLifecycle(), + DataStreamLifecycle.DEFAULT_DATA_LIFECYCLE, randomBoolean() ? new ErrorEntry( System.currentTimeMillis(), @@ -59,7 +59,7 @@ public void testGetGenerationTime() { now, randomBoolean() ? now + TimeValue.timeValueDays(1).getMillis() : null, TimeValue.timeValueMillis(now + 100), - new DataStreamLifecycle(), + DataStreamLifecycle.DEFAULT_DATA_LIFECYCLE, randomBoolean() ? new ErrorEntry( System.currentTimeMillis(), @@ -95,7 +95,7 @@ public void testGetGenerationTime() { now, now + 80L, // rolled over in the future (clocks are funny that way) TimeValue.timeValueMillis(now + 100L), - new DataStreamLifecycle(), + DataStreamLifecycle.DEFAULT_DATA_LIFECYCLE, null ); assertThat(indexDataStreamLifecycle.getGenerationTime(() -> now), is(TimeValue.ZERO)); @@ -107,7 +107,7 @@ public void testGetTimeSinceIndexCreation() { { ExplainIndexDataStreamLifecycle randomIndexDataStreamLifecycleExplanation = createManagedIndexDataStreamLifecycleExplanation( now, - new DataStreamLifecycle() + DataStreamLifecycle.DEFAULT_DATA_LIFECYCLE ); assertThat( randomIndexDataStreamLifecycleExplanation.getTimeSinceIndexCreation(() -> now + 75L), @@ -138,7 +138,7 @@ public void testGetTimeSinceIndexCreation() { now + 80L, // created in the future (clocks are funny that way) null, null, - new DataStreamLifecycle(), + DataStreamLifecycle.DEFAULT_DATA_LIFECYCLE, null ); assertThat(indexDataStreamLifecycle.getTimeSinceIndexCreation(() -> now), is(TimeValue.ZERO)); @@ -150,7 +150,7 @@ public void testGetTimeSinceRollover() { { ExplainIndexDataStreamLifecycle randomIndexDataStreamLifecycleExplanation = createManagedIndexDataStreamLifecycleExplanation( now, - new DataStreamLifecycle() + DataStreamLifecycle.DEFAULT_DATA_LIFECYCLE ); if (randomIndexDataStreamLifecycleExplanation.getRolloverDate() == null) { // age calculated since creation date @@ -188,7 +188,7 @@ public void testGetTimeSinceRollover() { now - 50L, now + 100L, // rolled over in the future TimeValue.timeValueMillis(now), - new DataStreamLifecycle(), + DataStreamLifecycle.DEFAULT_DATA_LIFECYCLE, null ); assertThat(indexDataStreamLifecycle.getTimeSinceRollover(() -> now), is(TimeValue.ZERO)); @@ -254,12 +254,18 @@ protected Writeable.Reader instanceReader() { @Override protected ExplainIndexDataStreamLifecycle createTestInstance() { - return createManagedIndexDataStreamLifecycleExplanation(System.nanoTime(), randomBoolean() ? new DataStreamLifecycle() : null); + return createManagedIndexDataStreamLifecycleExplanation( + System.nanoTime(), + randomBoolean() ? DataStreamLifecycle.DEFAULT_DATA_LIFECYCLE : null + ); } @Override protected ExplainIndexDataStreamLifecycle mutateInstance(ExplainIndexDataStreamLifecycle instance) throws IOException { - return createManagedIndexDataStreamLifecycleExplanation(System.nanoTime(), randomBoolean() ? new DataStreamLifecycle() : null); + return createManagedIndexDataStreamLifecycleExplanation( + System.nanoTime(), + randomBoolean() ? DataStreamLifecycle.DEFAULT_DATA_LIFECYCLE : null + ); } private static ExplainIndexDataStreamLifecycle createManagedIndexDataStreamLifecycleExplanation( diff --git a/server/src/test/java/org/elasticsearch/action/datastreams/lifecycle/GetDataStreamLifecycleActionTests.java b/server/src/test/java/org/elasticsearch/action/datastreams/lifecycle/GetDataStreamLifecycleActionTests.java index c48c473d46f9f..fdde637c783ff 100644 --- a/server/src/test/java/org/elasticsearch/action/datastreams/lifecycle/GetDataStreamLifecycleActionTests.java +++ b/server/src/test/java/org/elasticsearch/action/datastreams/lifecycle/GetDataStreamLifecycleActionTests.java @@ -35,7 +35,7 @@ public class GetDataStreamLifecycleActionTests extends ESTestCase { public void testDefaultLifecycleResponseToXContent() throws Exception { boolean isInternalDataStream = randomBoolean(); GetDataStreamLifecycleAction.Response.DataStreamLifecycle dataStreamLifecycle = createDataStreamLifecycle( - DataStreamLifecycle.DEFAULT, + DataStreamLifecycle.DEFAULT_DATA_LIFECYCLE, isInternalDataStream ); GetDataStreamLifecycleAction.Response response = new GetDataStreamLifecycleAction.Response(List.of(dataStreamLifecycle)); diff --git a/server/src/test/java/org/elasticsearch/cluster/metadata/ComponentTemplateTests.java b/server/src/test/java/org/elasticsearch/cluster/metadata/ComponentTemplateTests.java index d94e1e0532539..9dae5e416b3ee 100644 --- a/server/src/test/java/org/elasticsearch/cluster/metadata/ComponentTemplateTests.java +++ b/server/src/test/java/org/elasticsearch/cluster/metadata/ComponentTemplateTests.java @@ -286,7 +286,7 @@ public void testXContentSerializationWithRolloverAndEffectiveRetention() throws if (randomBoolean()) { dataStreamOptions = randomDataStreamOptionsTemplate(); } - DataStreamLifecycle.Template lifecycle = DataStreamLifecycle.Template.DEFAULT; + DataStreamLifecycle.Template lifecycle = DataStreamLifecycle.Template.DATA_DEFAULT; ComponentTemplate template = new ComponentTemplate( new Template(settings, mappings, aliases, lifecycle, dataStreamOptions), randomNonNegativeLong(), diff --git a/server/src/test/java/org/elasticsearch/cluster/metadata/ComposableIndexTemplateTests.java b/server/src/test/java/org/elasticsearch/cluster/metadata/ComposableIndexTemplateTests.java index ccd5f07a0556e..4bfde764fa3b1 100644 --- a/server/src/test/java/org/elasticsearch/cluster/metadata/ComposableIndexTemplateTests.java +++ b/server/src/test/java/org/elasticsearch/cluster/metadata/ComposableIndexTemplateTests.java @@ -236,7 +236,7 @@ public void testXContentSerializationWithRolloverAndEffectiveRetention() throws dataStreamOptions = ComponentTemplateTests.randomDataStreamOptionsTemplate(); } // We use the empty lifecycle so the global retention can be in effect - DataStreamLifecycle.Template lifecycle = DataStreamLifecycle.Template.DEFAULT; + DataStreamLifecycle.Template lifecycle = DataStreamLifecycle.Template.DATA_DEFAULT; Template template = new Template(settings, mappings, aliases, lifecycle, dataStreamOptions); ComposableIndexTemplate.builder() .indexPatterns(List.of(randomAlphaOfLength(4))) diff --git a/server/src/test/java/org/elasticsearch/cluster/metadata/DataStreamLifecycleTests.java b/server/src/test/java/org/elasticsearch/cluster/metadata/DataStreamLifecycleTests.java index 3010cc8bd1145..cc4c1e022f486 100644 --- a/server/src/test/java/org/elasticsearch/cluster/metadata/DataStreamLifecycleTests.java +++ b/server/src/test/java/org/elasticsearch/cluster/metadata/DataStreamLifecycleTests.java @@ -135,7 +135,7 @@ public void testXContentDeSerializationWithNullValues() throws IOException { var parsed = DataStreamLifecycle.fromXContent(parser); assertEquals(XContentParser.Token.END_OBJECT, parser.currentToken()); assertNull(parser.nextToken()); - assertThat(parsed, equalTo(DataStreamLifecycle.DEFAULT)); + assertThat(parsed, equalTo(DataStreamLifecycle.DEFAULT_DATA_LIFECYCLE)); } } diff --git a/server/src/test/java/org/elasticsearch/cluster/metadata/DataStreamLifecycleWithRetentionWarningsTests.java b/server/src/test/java/org/elasticsearch/cluster/metadata/DataStreamLifecycleWithRetentionWarningsTests.java index 75b504e64117d..51b8b22c5686a 100644 --- a/server/src/test/java/org/elasticsearch/cluster/metadata/DataStreamLifecycleWithRetentionWarningsTests.java +++ b/server/src/test/java/org/elasticsearch/cluster/metadata/DataStreamLifecycleWithRetentionWarningsTests.java @@ -145,10 +145,14 @@ public void testUpdatingLifecycleOnADataStream() { DataStreamGlobalRetentionSettings.create(ClusterSettings.createBuiltInClusterSettings(settingsWithDefaultRetention)) ); - ProjectMetadata after = metadataDataStreamsService.updateDataLifecycle(before, List.of(dataStream), DataStreamLifecycle.DEFAULT); + ProjectMetadata after = metadataDataStreamsService.updateDataLifecycle( + before, + List.of(dataStream), + DataStreamLifecycle.DEFAULT_DATA_LIFECYCLE + ); DataStream updatedDataStream = after.dataStreams().get(dataStream); assertNotNull(updatedDataStream); - assertThat(updatedDataStream.getDataLifecycle(), equalTo(DataStreamLifecycle.DEFAULT)); + assertThat(updatedDataStream.getDataLifecycle(), equalTo(DataStreamLifecycle.DEFAULT_DATA_LIFECYCLE)); Map> responseHeaders = threadContext.getResponseHeaders(); assertThat(responseHeaders.size(), is(1)); assertThat( @@ -169,7 +173,7 @@ public void testValidateLifecycleIndexTemplateWithWarning() { ProjectMetadata.builder(randomProjectIdOrDefault()).build(), randomAlphaOfLength(10), ComposableIndexTemplate.builder() - .template(Template.builder().lifecycle(DataStreamLifecycle.Template.DEFAULT)) + .template(Template.builder().lifecycle(DataStreamLifecycle.Template.DATA_DEFAULT)) .dataStreamTemplate(new ComposableIndexTemplate.DataStreamTemplate()) .indexPatterns(List.of(randomAlphaOfLength(10))) .build(), @@ -195,7 +199,7 @@ public void testValidateInternalDataStreamRetentionWithoutWarning() { ProjectMetadata.builder(randomProjectIdOrDefault()).build(), randomAlphaOfLength(10), ComposableIndexTemplate.builder() - .template(Template.builder().lifecycle(DataStreamLifecycle.Template.DEFAULT)) + .template(Template.builder().lifecycle(DataStreamLifecycle.Template.DATA_DEFAULT)) .dataStreamTemplate(new ComposableIndexTemplate.DataStreamTemplate()) .indexPatterns(List.of("." + randomAlphaOfLength(10))) .build(), @@ -229,7 +233,7 @@ public void testValidateLifecycleComponentTemplateWithWarning() { .build(), randomAlphaOfLength(10), ComposableIndexTemplate.builder() - .template(Template.builder().lifecycle(DataStreamLifecycle.Template.DEFAULT)) + .template(Template.builder().lifecycle(DataStreamLifecycle.Template.DATA_DEFAULT)) .dataStreamTemplate(new ComposableIndexTemplate.DataStreamTemplate()) .indexPatterns(List.of(randomAlphaOfLength(10))) .componentTemplates(List.of("component-template")) @@ -282,7 +286,7 @@ public void testValidateLifecycleInComponentTemplate() throws Exception { Template template = Template.builder() .settings(ComponentTemplateTests.randomSettings()) .aliases(ComponentTemplateTests.randomAliases()) - .lifecycle(DataStreamLifecycle.Template.DEFAULT) + .lifecycle(DataStreamLifecycle.Template.DATA_DEFAULT) .build(); ComponentTemplate componentTemplate = new ComponentTemplate(template, 1L, new HashMap<>()); project = metadataIndexTemplateService.addComponentTemplate(project, false, "foo", componentTemplate); diff --git a/server/src/test/java/org/elasticsearch/cluster/metadata/DataStreamTests.java b/server/src/test/java/org/elasticsearch/cluster/metadata/DataStreamTests.java index c93c9a93b9e50..ee911edd1789d 100644 --- a/server/src/test/java/org/elasticsearch/cluster/metadata/DataStreamTests.java +++ b/server/src/test/java/org/elasticsearch/cluster/metadata/DataStreamTests.java @@ -1388,7 +1388,7 @@ public void testGetBackingIndicesPastRetention() { dataStreamName, creationAndRolloverTimes, settings(IndexVersion.current()), - new DataStreamLifecycle() { + new DataStreamLifecycle(null, null, null) { public TimeValue dataRetention() { return retention.get(); } @@ -1538,7 +1538,7 @@ public void testGetFailureIndicesPastRetention() { dataStreamName, creationAndRolloverTimes, settings(IndexVersion.current()), - new DataStreamLifecycle() { + new DataStreamLifecycle(null, null, null) { public TimeValue dataRetention() { return retention.get(); } @@ -1649,7 +1649,7 @@ public void testBackingIndicesPastRetentionWithOriginationDate() { dataStreamName, creationAndRolloverTimes, settings(IndexVersion.current()), - new DataStreamLifecycle() { + new DataStreamLifecycle(null, null, null) { public TimeValue dataRetention() { return testRetentionReference.get(); } @@ -1700,7 +1700,7 @@ public void testFailureIndicesPastRetentionWithOriginationDate() { dataStreamName, creationAndRolloverTimes, settings(IndexVersion.current()), - new DataStreamLifecycle() { + new DataStreamLifecycle(null, null, null) { public TimeValue dataRetention() { return testRetentionReference.get(); } @@ -1956,7 +1956,7 @@ public void testIsIndexManagedByDataStreamLifecycle() { Settings.builder() .put(IndexMetadata.LIFECYCLE_NAME, "ILM_policy") .put(IndexMetadata.SETTING_VERSION_CREATED, IndexVersion.current()), - new DataStreamLifecycle() + DataStreamLifecycle.DEFAULT_DATA_LIFECYCLE ); Metadata metadataIlm = builderWithIlm.build(); for (Index index : ds.getIndices()) { @@ -1977,7 +1977,7 @@ public void testIsIndexManagedByDataStreamLifecycle() { .put(IndexMetadata.LIFECYCLE_NAME, "ILM_policy") .put(IndexMetadata.SETTING_VERSION_CREATED, IndexVersion.current()) .put(IndexSettings.PREFER_ILM, false), - new DataStreamLifecycle() + DataStreamLifecycle.DEFAULT_DATA_LIFECYCLE ); Metadata metadataIlm = builderWithIlm.build(); for (Index index : ds.getIndices()) { @@ -2077,7 +2077,7 @@ public void testXContentSerializationWithRolloverAndEffectiveRetention() throws failureIndices = randomNonEmptyIndexInstances(); } - DataStreamLifecycle lifecycle = new DataStreamLifecycle(); + DataStreamLifecycle lifecycle = DataStreamLifecycle.DEFAULT_DATA_LIFECYCLE; boolean isSystem = randomBoolean(); DataStream dataStream = new DataStream( dataStreamName, diff --git a/server/src/test/java/org/elasticsearch/cluster/metadata/MetadataCreateDataStreamServiceTests.java b/server/src/test/java/org/elasticsearch/cluster/metadata/MetadataCreateDataStreamServiceTests.java index 7557f84eaac83..b2d1dada3eaeb 100644 --- a/server/src/test/java/org/elasticsearch/cluster/metadata/MetadataCreateDataStreamServiceTests.java +++ b/server/src/test/java/org/elasticsearch/cluster/metadata/MetadataCreateDataStreamServiceTests.java @@ -80,7 +80,7 @@ public void testCreateDataStream() throws Exception { assertThat(project.dataStreams().get(dataStreamName).isSystem(), is(false)); assertThat(project.dataStreams().get(dataStreamName).isHidden(), is(false)); assertThat(project.dataStreams().get(dataStreamName).isReplicated(), is(false)); - assertThat(project.dataStreams().get(dataStreamName).getDataLifecycle(), equalTo(DataStreamLifecycle.DEFAULT)); + assertThat(project.dataStreams().get(dataStreamName).getDataLifecycle(), equalTo(DataStreamLifecycle.DEFAULT_DATA_LIFECYCLE)); assertThat(project.dataStreams().get(dataStreamName).getIndexMode(), nullValue()); assertThat(project.index(DataStream.getDefaultBackingIndexName(dataStreamName, 1)), notNullValue()); assertThat( @@ -119,7 +119,7 @@ public void testCreateDataStreamLogsdb() throws Exception { assertThat(project.dataStreams().get(dataStreamName).isHidden(), is(false)); assertThat(project.dataStreams().get(dataStreamName).isReplicated(), is(false)); assertThat(project.dataStreams().get(dataStreamName).getIndexMode(), equalTo(IndexMode.LOGSDB)); - assertThat(project.dataStreams().get(dataStreamName).getDataLifecycle(), equalTo(DataStreamLifecycle.DEFAULT)); + assertThat(project.dataStreams().get(dataStreamName).getDataLifecycle(), equalTo(DataStreamLifecycle.DEFAULT_DATA_LIFECYCLE)); assertThat(project.index(DataStream.getDefaultBackingIndexName(dataStreamName, 1)), notNullValue()); assertThat( project.index(DataStream.getDefaultBackingIndexName(dataStreamName, 1)).getSettings().get("index.hidden"), diff --git a/server/src/test/java/org/elasticsearch/cluster/metadata/MetadataIndexTemplateServiceTests.java b/server/src/test/java/org/elasticsearch/cluster/metadata/MetadataIndexTemplateServiceTests.java index e7953bc329634..207cd8f2dc3ef 100644 --- a/server/src/test/java/org/elasticsearch/cluster/metadata/MetadataIndexTemplateServiceTests.java +++ b/server/src/test/java/org/elasticsearch/cluster/metadata/MetadataIndexTemplateServiceTests.java @@ -1488,7 +1488,7 @@ public void testResolveLifecycle() throws Exception { MetadataIndexTemplateService service = getMetadataIndexTemplateService(); ProjectMetadata project = ProjectMetadata.builder(randomProjectIdOrDefault()).build(); - DataStreamLifecycle.Template emptyLifecycle = DataStreamLifecycle.Template.DEFAULT; + DataStreamLifecycle.Template emptyLifecycle = DataStreamLifecycle.Template.DATA_DEFAULT; DataStreamLifecycle.Template lifecycle30d = DataStreamLifecycle.builder() .dataRetention(TimeValue.timeValueDays(30)) @@ -1565,7 +1565,7 @@ public void testResolveLifecycle() throws Exception { // Composable Z: - // Result: "lifecycle": {"enabled": true}, here the result of the composition is with retention explicitly // nullified, but effectively this is equivalent to infinite retention. - assertLifecycleResolution(service, project, List.of(ct30d, ctNullRetention), null, DataStreamLifecycle.Template.DEFAULT); + assertLifecycleResolution(service, project, List.of(ct30d, ctNullRetention), null, DataStreamLifecycle.Template.DATA_DEFAULT); // Component A: "lifecycle": {"enabled": true} // Component B: "lifecycle": {"retention": "45d", "downsampling": [{"after": "30d", "fixed_interval": "3h"}]} diff --git a/server/src/test/java/org/elasticsearch/cluster/metadata/MetadataIsManagedByILMTests.java b/server/src/test/java/org/elasticsearch/cluster/metadata/MetadataIsManagedByILMTests.java index 4f69659984d4c..73f43411ccb0c 100644 --- a/server/src/test/java/org/elasticsearch/cluster/metadata/MetadataIsManagedByILMTests.java +++ b/server/src/test/java/org/elasticsearch/cluster/metadata/MetadataIsManagedByILMTests.java @@ -66,7 +66,7 @@ public void testIsIndexManagedByILM() { 1, null, false, - new DataStreamLifecycle() + DataStreamLifecycle.DEFAULT_DATA_LIFECYCLE ); Metadata metadata = Metadata.builder().put(indexMetadata, true).put(dataStream).build(); @@ -89,7 +89,7 @@ public void testIsIndexManagedByILM() { 1, null, false, - new DataStreamLifecycle() + DataStreamLifecycle.DEFAULT_DATA_LIFECYCLE ); Metadata metadata = Metadata.builder().put(indexMetadata, true).put(dataStream).build(); diff --git a/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/datastreams/DataStreamLifecycleFeatureSetUsageTests.java b/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/datastreams/DataStreamLifecycleFeatureSetUsageTests.java index 9f2c346ca517a..bd203a2143d73 100644 --- a/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/datastreams/DataStreamLifecycleFeatureSetUsageTests.java +++ b/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/datastreams/DataStreamLifecycleFeatureSetUsageTests.java @@ -109,7 +109,7 @@ public void testLifecycleStats() { 1L, null, false, - new DataStreamLifecycle() + DataStreamLifecycle.DEFAULT_DATA_LIFECYCLE ), DataStreamTestHelper.newInstance( randomAlphaOfLength(10), diff --git a/x-pack/plugin/ilm/src/internalClusterTest/java/org/elasticsearch/xpack/ilm/DataStreamAndIndexLifecycleMixingTests.java b/x-pack/plugin/ilm/src/internalClusterTest/java/org/elasticsearch/xpack/ilm/DataStreamAndIndexLifecycleMixingTests.java index 9fb04a96282e4..873da8c86d4e2 100644 --- a/x-pack/plugin/ilm/src/internalClusterTest/java/org/elasticsearch/xpack/ilm/DataStreamAndIndexLifecycleMixingTests.java +++ b/x-pack/plugin/ilm/src/internalClusterTest/java/org/elasticsearch/xpack/ilm/DataStreamAndIndexLifecycleMixingTests.java @@ -207,7 +207,7 @@ public void testIndexTemplateSwapsILMForDataStreamLifecycle() throws Exception { TEST_REQUEST_TIMEOUT, TEST_REQUEST_TIMEOUT, new String[] { dataStreamName }, - new DataStreamLifecycle() + DataStreamLifecycle.DEFAULT_DATA_LIFECYCLE ) ).actionGet(); @@ -337,7 +337,7 @@ public void testUpdateIndexTemplateFromILMtoBothILMAndDataStreamLifecycle() thro List.of(dataStreamName + "*"), Settings.builder().put(LifecycleSettings.LIFECYCLE_NAME, policy).build(), null, - DataStreamLifecycle.Template.DEFAULT + DataStreamLifecycle.Template.DATA_DEFAULT ); indexDocs(dataStreamName, 2); @@ -385,7 +385,7 @@ public void testUpdateIndexTemplateFromILMtoBothILMAndDataStreamLifecycle() thro List.of(dataStreamName + "*"), Settings.builder().put(IndexSettings.PREFER_ILM, false).put(LifecycleSettings.LIFECYCLE_NAME, policy).build(), null, - DataStreamLifecycle.Template.DEFAULT + DataStreamLifecycle.Template.DATA_DEFAULT ); // note that all indices now are still managed by ILM, so we index 2 documents. the new write index will be managed by the data @@ -541,7 +541,7 @@ public void testUpdateIndexTemplateToDataStreamLifecyclePreference() throws Exce TEST_REQUEST_TIMEOUT, TEST_REQUEST_TIMEOUT, new String[] { dataStreamName }, - new DataStreamLifecycle() + DataStreamLifecycle.DEFAULT_DATA_LIFECYCLE ) ).actionGet(); @@ -660,7 +660,7 @@ public void testUpdateIndexTemplateToMigrateFromDataStreamLifecycleToIlm() throw List.of(dataStreamName + "*"), null, null, - DataStreamLifecycle.Template.DEFAULT + DataStreamLifecycle.Template.DATA_DEFAULT ); // this will create the data stream and trigger a rollover so we will end up with a data stream with 2 backing indices diff --git a/x-pack/plugin/security/src/internalClusterTest/java/org/elasticsearch/integration/DataStreamLifecycleServiceRuntimeSecurityIT.java b/x-pack/plugin/security/src/internalClusterTest/java/org/elasticsearch/integration/DataStreamLifecycleServiceRuntimeSecurityIT.java index c1a031823a25b..b736e5680c7e0 100644 --- a/x-pack/plugin/security/src/internalClusterTest/java/org/elasticsearch/integration/DataStreamLifecycleServiceRuntimeSecurityIT.java +++ b/x-pack/plugin/security/src/internalClusterTest/java/org/elasticsearch/integration/DataStreamLifecycleServiceRuntimeSecurityIT.java @@ -95,7 +95,7 @@ protected Settings nodeSettings(int nodeOrdinal, Settings otherSettings) { public void testRolloverLifecycleAndForceMergeAuthorized() throws Exception { String dataStreamName = randomDataStreamName(); // empty lifecycle contains the default rollover - prepareDataStreamAndIndex(dataStreamName, DataStreamLifecycle.Template.DEFAULT); + prepareDataStreamAndIndex(dataStreamName, DataStreamLifecycle.Template.DATA_DEFAULT); List backingIndices = waitForDataStreamBackingIndices(dataStreamName, 2); String backingIndex = backingIndices.get(0); @@ -130,7 +130,7 @@ public void testRolloverAndRetentionAuthorized() throws Exception { public void testUnauthorized() throws Exception { // this is an example index pattern for a system index that the data stream lifecycle does not have access for. Data stream // lifecycle will therefore fail at runtime with an authz exception - prepareDataStreamAndIndex(SECURITY_MAIN_ALIAS, DataStreamLifecycle.Template.DEFAULT); + prepareDataStreamAndIndex(SECURITY_MAIN_ALIAS, DataStreamLifecycle.Template.DATA_DEFAULT); assertBusy(() -> { Map indicesAndErrors = collectErrorsFromStoreAsMap();