Module org.elasticsearch.server
Class MetadataRolloverService
java.lang.Object
org.elasticsearch.action.admin.indices.rollover.MetadataRolloverService
Service responsible for handling rollover requests for write aliases and data streams
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic final recordstatic final record -
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionMetadataRolloverService(ThreadPool threadPool, MetadataCreateIndexService createIndexService, MetadataIndexAliasesService indexAliasesService, SystemIndices systemIndices, WriteLoadForecaster writeLoadForecaster, ClusterService clusterService, TelemetryProvider telemetryProvider) -
Method Summary
Modifier and TypeMethodDescriptionresolveRolloverNames(ClusterState currentState, String rolloverTarget, String newIndexName, CreateIndexRequest createIndexRequest, boolean isFailureStoreRollover) Returns the names that rollover would use, but does not perform the actual rolloverrolloverClusterState(ClusterState currentState, String rolloverTarget, String newIndexName, CreateIndexRequest createIndexRequest, List<Condition<?>> metConditions, Instant now, boolean silent, boolean onlyValidate, IndexMetadataStats sourceIndexStats, AutoShardingResult autoShardingResult, boolean isFailureStoreRollover) withShardSizeForecastForWriteIndex(String dataStreamName, Metadata.Builder metadata)
-
Field Details
-
HIDDEN_INDEX_SETTINGS
-
AUTO_SHARDING_METRIC_NAMES
-
-
Constructor Details
-
MetadataRolloverService
@Inject public MetadataRolloverService(ThreadPool threadPool, MetadataCreateIndexService createIndexService, MetadataIndexAliasesService indexAliasesService, SystemIndices systemIndices, WriteLoadForecaster writeLoadForecaster, ClusterService clusterService, TelemetryProvider telemetryProvider)
-
-
Method Details
-
rolloverClusterState
public MetadataRolloverService.RolloverResult rolloverClusterState(ClusterState currentState, String rolloverTarget, String newIndexName, CreateIndexRequest createIndexRequest, List<Condition<?>> metConditions, Instant now, boolean silent, boolean onlyValidate, @Nullable IndexMetadataStats sourceIndexStats, @Nullable AutoShardingResult autoShardingResult, boolean isFailureStoreRollover) throws Exception - Throws:
Exception
-
resolveRolloverNames
public static MetadataRolloverService.NameResolution resolveRolloverNames(ClusterState currentState, String rolloverTarget, String newIndexName, CreateIndexRequest createIndexRequest, boolean isFailureStoreRollover) Returns the names that rollover would use, but does not perform the actual rollover -
withShardSizeForecastForWriteIndex
public Metadata.Builder withShardSizeForecastForWriteIndex(String dataStreamName, Metadata.Builder metadata)
-