|
@@ -1114,7 +1114,10 @@ public class LogsdbIndexModeSettingsProviderTests extends ESTestCase {
|
|
|
}
|
|
|
|
|
|
public void testSortAndHostNameObject() throws Exception {
|
|
|
- var settings = Settings.builder().put(IndexSettings.MODE.getKey(), IndexMode.LOGSDB).build();
|
|
|
+ var settings = Settings.builder()
|
|
|
+ .put(IndexSettings.MODE.getKey(), IndexMode.LOGSDB)
|
|
|
+ .put(IndexSettings.INDEX_FAST_REFRESH_SETTING.getKey(), true)
|
|
|
+ .build();
|
|
|
var mappings = """
|
|
|
{
|
|
|
"_doc": {
|
|
@@ -1134,4 +1137,48 @@ public class LogsdbIndexModeSettingsProviderTests extends ESTestCase {
|
|
|
assertFalse(IndexSettings.LOGSDB_ADD_HOST_NAME_FIELD.get(result));
|
|
|
assertEquals(1, newMapperServiceCounter.get());
|
|
|
}
|
|
|
+
|
|
|
+ public void testSortFastRefresh() throws Exception {
|
|
|
+ var settings = Settings.builder()
|
|
|
+ .put(IndexSettings.MODE.getKey(), IndexMode.LOGSDB)
|
|
|
+ .put(IndexSettings.INDEX_FAST_REFRESH_SETTING.getKey(), true)
|
|
|
+ .build();
|
|
|
+ var mappings = """
|
|
|
+ {
|
|
|
+ "_doc": {
|
|
|
+ "properties": {
|
|
|
+ "@timestamp": {
|
|
|
+ "type": "date"
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ """;
|
|
|
+
|
|
|
+ String systemIndex = ".security-profile";
|
|
|
+ Metadata metadata = Metadata.EMPTY_METADATA;
|
|
|
+ var provider = new LogsdbIndexModeSettingsProvider(
|
|
|
+ logsdbLicenseService,
|
|
|
+ Settings.builder().put("cluster.logsdb.enabled", true).build()
|
|
|
+ );
|
|
|
+ provider.init(
|
|
|
+ im -> MapperTestUtils.newMapperService(xContentRegistry(), createTempDir(), im.getSettings(), im.getIndex().getName()),
|
|
|
+ IndexVersion::current,
|
|
|
+ () -> Version.CURRENT,
|
|
|
+ true,
|
|
|
+ true
|
|
|
+ );
|
|
|
+ var additionalIndexSettings = provider.getAdditionalIndexSettings(
|
|
|
+ DataStream.getDefaultBackingIndexName(systemIndex, 0),
|
|
|
+ systemIndex,
|
|
|
+ IndexMode.LOGSDB,
|
|
|
+ metadata.getProject(),
|
|
|
+ Instant.now(),
|
|
|
+ settings,
|
|
|
+ List.of(new CompressedXContent(mappings))
|
|
|
+ );
|
|
|
+
|
|
|
+ Settings result = builder().put(additionalIndexSettings).build();
|
|
|
+ assertTrue(IndexSettings.LOGSDB_SORT_ON_HOST_NAME.get(result));
|
|
|
+ }
|
|
|
}
|