Package org.elasticsearch.indices.cluster

Interface IndicesClusterStateService.AllocatedIndices<T extends IndicesClusterStateService.Shard,U extends IndicesClusterStateService.AllocatedIndex<T>>

All Superinterfaces:

java.lang.Iterable<U>

All Known Implementing Classes:

IndicesService

Enclosing class:

IndicesClusterStateService

public static interface IndicesClusterStateService.AllocatedIndices<T extends IndicesClusterStateService.Shard,U extends IndicesClusterStateService.AllocatedIndex<T>>
extends java.lang.Iterable<U>

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	IndicesClusterStateService.AllocatedIndices.IndexRemovalReason

Method Summary

Modifier and Type	Method	Description
U	createIndex(IndexMetaData indexMetaData, java.util.List<IndexEventListener> builtInIndexListener)	Creates a new IndexService for the given metadata.
T	createShard(ShardRouting shardRouting, RecoveryState recoveryState, PeerRecoveryTargetService recoveryTargetService, PeerRecoveryTargetService.RecoveryListener recoveryListener, RepositoriesService repositoriesService, java.util.function.Consumer<IndexShard.ShardFailure> onShardFailure, java.util.function.Consumer<ShardId> globalCheckpointSyncer)	Creates shard for the specified shard routing and starts recovery,
void	deleteUnassignedIndex(java.lang.String reason, IndexMetaData metaData, ClusterState clusterState)	Deletes an index that is not assigned to this node.
default T	getShardOrNull(ShardId shardId)	Returns shard for the specified id if it exists otherwise returns null.
U	indexService(Index index)	Returns an IndexService for the specified index if exists otherwise returns null.
void	processPendingDeletes(Index index, IndexSettings indexSettings, TimeValue timeValue)
void	removeIndex(Index index, IndicesClusterStateService.AllocatedIndices.IndexRemovalReason reason, java.lang.String extraInfo)	Removes the given index from this service and releases all associated resources.
IndexMetaData	verifyIndexIsDeleted(Index index, ClusterState clusterState)	Verify that the contents on disk for the given index is deleted; if not, delete the contents.

Methods inherited from interface java.lang.Iterable

forEach, iterator, spliterator

Method Detail

createIndex

U createIndex(IndexMetaData indexMetaData,
              java.util.List<IndexEventListener> builtInIndexListener)
       throws java.io.IOException

Creates a new IndexService for the given metadata.

Parameters:

indexMetaData - the index metadata to create the index for

builtInIndexListener - a list of built-in lifecycle IndexEventListener that should should be used along side with the per-index listeners

Throws:

ResourceAlreadyExistsException - if the index already exists.

java.io.IOException

verifyIndexIsDeleted

IndexMetaData verifyIndexIsDeleted(Index index,
                                   ClusterState clusterState)

Verify that the contents on disk for the given index is deleted; if not, delete the contents. This method assumes that an index is already deleted in the cluster state and/or explicitly through index tombstones.

Parameters:

index - Index to make sure its deleted from disk

clusterState - ClusterState to ensure the index is not part of it

Returns:

IndexMetaData for the index loaded from disk

deleteUnassignedIndex

void deleteUnassignedIndex(java.lang.String reason,
                           IndexMetaData metaData,
                           ClusterState clusterState)

Deletes an index that is not assigned to this node. This method cleans up all disk folders relating to the index but does not deal with in-memory structures. For those call removeIndex(Index, IndexRemovalReason, String)

removeIndex

void removeIndex(Index index,
                 IndicesClusterStateService.AllocatedIndices.IndexRemovalReason reason,
                 java.lang.String extraInfo)

Removes the given index from this service and releases all associated resources. Persistent parts of the index like the shards files, state and transaction logs are kept around in the case of a disaster recovery.

Parameters:

index - the index to remove

reason - the reason to remove the index

extraInfo - extra information that will be used for logging and reporting

indexService

@Nullable
U indexService(Index index)

Returns an IndexService for the specified index if exists otherwise returns null.

createShard

T createShard(ShardRouting shardRouting,
              RecoveryState recoveryState,
              PeerRecoveryTargetService recoveryTargetService,
              PeerRecoveryTargetService.RecoveryListener recoveryListener,
              RepositoriesService repositoriesService,
              java.util.function.Consumer<IndexShard.ShardFailure> onShardFailure,
              java.util.function.Consumer<ShardId> globalCheckpointSyncer)
       throws java.io.IOException

Creates shard for the specified shard routing and starts recovery,

Throws:

java.io.IOException

getShardOrNull

default T getShardOrNull(ShardId shardId)

Returns shard for the specified id if it exists otherwise returns null.

processPendingDeletes

void processPendingDeletes(Index index,
                           IndexSettings indexSettings,
                           TimeValue timeValue)
                    throws java.io.IOException,
                           java.lang.InterruptedException,
                           ShardLockObtainFailedException

Throws:

java.io.IOException

java.lang.InterruptedException

ShardLockObtainFailedException