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-
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, 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, 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>
-