Class AbstractIndicesClusterStateServiceTestCase.MockIndexShard
java.lang.Object
org.elasticsearch.indices.cluster.AbstractIndicesClusterStateServiceTestCase.MockIndexShard
- All Implemented Interfaces:
IndicesClusterStateService.Shard
- Enclosing class:
AbstractIndicesClusterStateServiceTestCase
protected class AbstractIndicesClusterStateServiceTestCase.MockIndexShard
extends Object
implements IndicesClusterStateService.Shard
Mock for
IndexShard-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionshardId()state()longterm()voidupdateShardState(ShardRouting shardRouting, long newPrimaryTerm, BiConsumer<IndexShard, ActionListener<PrimaryReplicaSyncer.ResyncTask>> primaryReplicaSyncer, long applyingClusterStateVersion, Set<String> inSyncAllocationIds, IndexShardRoutingTable routingTable) voidupdateTerm(long newTerm)
-
Constructor Details
-
MockIndexShard
-
-
Method Details
-
shardId
- Specified by:
shardIdin interfaceIndicesClusterStateService.Shard
-
recoveryState
- Specified by:
recoveryStatein interfaceIndicesClusterStateService.Shard
-
updateShardState
public void updateShardState(ShardRouting shardRouting, long newPrimaryTerm, BiConsumer<IndexShard, ActionListener<PrimaryReplicaSyncer.ResyncTask>> primaryReplicaSyncer, long applyingClusterStateVersion, Set<String> inSyncAllocationIds, IndexShardRoutingTable routingTable) throws IOException- Specified by:
updateShardStatein interfaceIndicesClusterStateService.Shard- Throws:
IOException
-
routingEntry
- Specified by:
routingEntryin interfaceIndicesClusterStateService.Shard
-
state
- Specified by:
statein interfaceIndicesClusterStateService.Shard
-
term
public long term() -
updateTerm
public void updateTerm(long newTerm) -
getTimestampRange
- Specified by:
getTimestampRangein interfaceIndicesClusterStateService.Shard
-
getEventIngestedRange
- Specified by:
getEventIngestedRangein interfaceIndicesClusterStateService.Shard
-