org.elasticsearch.gateway

Class DanglingIndicesState

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.elasticsearch.gateway.DanglingIndicesState

All Implemented Interfaces:

ClusterStateListener

public class DanglingIndicesState
extends AbstractComponent
implements ClusterStateListener

The dangling indices state is responsible for finding new dangling indices (indices that have their state written on disk, but don't exists in the metadata of the cluster), and importing them into the cluster.

Field Summary

Fields inherited from class org.elasticsearch.common.component.AbstractComponent

deprecationLogger, logger, settings

Constructor Summary

Constructors

Constructor and Description
DanglingIndicesState(Settings settings, NodeEnvironment nodeEnv, MetaStateService metaStateService, LocalAllocateDangledIndices allocateDangledIndices, ClusterService clusterService)

Method Summary

Modifier and Type	Method and Description
void	clusterChanged(ClusterChangedEvent event) Called when cluster state changes.
void	processDanglingIndices(MetaData metaData) Process dangling indices based on the provided meta data, handling cleanup, finding new dangling indices, and allocating outstanding ones.

Methods inherited from class org.elasticsearch.common.component.AbstractComponent

logDeprecatedSetting, logRemovedSetting, nodeName

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DanglingIndicesState

@Inject
public DanglingIndicesState(Settings settings,
                                    NodeEnvironment nodeEnv,
                                    MetaStateService metaStateService,
                                    LocalAllocateDangledIndices allocateDangledIndices,
                                    ClusterService clusterService)

Method Detail

processDanglingIndices

public void processDanglingIndices(MetaData metaData)

Process dangling indices based on the provided meta data, handling cleanup, finding new dangling indices, and allocating outstanding ones.

clusterChanged

public void clusterChanged(ClusterChangedEvent event)

Description copied from interface: ClusterStateListener

Called when cluster state changes.

Specified by:

clusterChanged in interface ClusterStateListener