Class AbstractIndicesClusterStateServiceTestCase.MockIndicesService
java.lang.Object
org.elasticsearch.indices.cluster.AbstractIndicesClusterStateServiceTestCase.MockIndicesService
- All Implemented Interfaces:
Iterable<AbstractIndicesClusterStateServiceTestCase.MockIndexService>,IndicesClusterStateService.AllocatedIndices<AbstractIndicesClusterStateServiceTestCase.MockIndexShard,AbstractIndicesClusterStateServiceTestCase.MockIndexService>
- Enclosing class:
AbstractIndicesClusterStateServiceTestCase
protected class AbstractIndicesClusterStateServiceTestCase.MockIndicesService
extends Object
implements IndicesClusterStateService.AllocatedIndices<AbstractIndicesClusterStateServiceTestCase.MockIndexShard,AbstractIndicesClusterStateServiceTestCase.MockIndexService>
Mock for
IndicesService-
Nested Class Summary
Nested classes/interfaces inherited from interface org.elasticsearch.indices.cluster.IndicesClusterStateService.AllocatedIndices
IndicesClusterStateService.AllocatedIndices.IndexRemovalReason -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptioncreateIndex(IndexMetadata indexMetadata, List<IndexEventListener> buildInIndexListener, boolean writeDanglingIndices) voidcreateShard(ShardRouting shardRouting, PeerRecoveryTargetService recoveryTargetService, PeerRecoveryTargetService.RecoveryListener recoveryListener, RepositoriesService repositoriesService, Consumer<IndexShard.ShardFailure> onShardFailure, GlobalCheckpointSyncer globalCheckpointSyncer, RetentionLeaseSyncer retentionLeaseSyncer, DiscoveryNode targetNode, DiscoveryNode sourceNode, long clusterStateVersion) voiddeleteUnassignedIndex(String reason, IndexMetadata metadata, ClusterState clusterState) indexService(Index index) iterator()voidprocessPendingDeletes(Index index, IndexSettings indexSettings, org.elasticsearch.core.TimeValue timeValue) voidremoveIndex(Index index, IndicesClusterStateService.AllocatedIndices.IndexRemovalReason reason, String extraInfo, Executor shardCloseExecutor, ActionListener<Void> shardsClosedListener) verifyIndexIsDeleted(Index index, ClusterState state) Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.elasticsearch.indices.cluster.IndicesClusterStateService.AllocatedIndices
getShardOrNullMethods inherited from interface java.lang.Iterable
forEach, spliterator
-
Constructor Details
-
MockIndicesService
protected MockIndicesService()
-
-
Method Details
-
createIndex
public AbstractIndicesClusterStateServiceTestCase.MockIndexService createIndex(IndexMetadata indexMetadata, List<IndexEventListener> buildInIndexListener, boolean writeDanglingIndices) throws IOException -
verifyIndexIsDeleted
-
deleteUnassignedIndex
-
removeIndex
public void removeIndex(Index index, IndicesClusterStateService.AllocatedIndices.IndexRemovalReason reason, String extraInfo, Executor shardCloseExecutor, ActionListener<Void> shardsClosedListener) -
indexService
@Nullable public AbstractIndicesClusterStateServiceTestCase.MockIndexService indexService(Index index) -
createShard
public void createShard(ShardRouting shardRouting, PeerRecoveryTargetService recoveryTargetService, PeerRecoveryTargetService.RecoveryListener recoveryListener, RepositoriesService repositoriesService, Consumer<IndexShard.ShardFailure> onShardFailure, GlobalCheckpointSyncer globalCheckpointSyncer, RetentionLeaseSyncer retentionLeaseSyncer, DiscoveryNode targetNode, DiscoveryNode sourceNode, long clusterStateVersion) throws IOException -
processPendingDeletes
public void processPendingDeletes(Index index, IndexSettings indexSettings, org.elasticsearch.core.TimeValue timeValue) -
iterator
- Specified by:
iteratorin interfaceIterable<AbstractIndicesClusterStateServiceTestCase.MockIndexService>
-