Package org.elasticsearch.indices.cluster

Interface IndicesClusterStateService.Shard

All Known Implementing Classes:

IndexShard

Enclosing class:

IndicesClusterStateService

public static interface IndicesClusterStateService.Shard

Method Summary

Modifier and Type	Method	Description
RecoveryState	recoveryState()	Returns the recovery state associated with this shard.
ShardRouting	routingEntry()	Returns the latest cluster routing entry received with this shard.
ShardId	shardId()	Returns the shard id of this shard.
IndexShardState	state()	Returns the latest internal shard state.
void	updateShardState(ShardRouting shardRouting, long primaryTerm, java.util.function.BiConsumer<IndexShard,ActionListener<PrimaryReplicaSyncer.ResyncTask>> primaryReplicaSyncer, long applyingClusterStateVersion, java.util.Set<java.lang.String> inSyncAllocationIds, IndexShardRoutingTable routingTable, java.util.Set<java.lang.String> pre60AllocationIds)	Updates the shard state based on an incoming cluster state: - Updates and persists the new routing value.

Method Detail

shardId

ShardId shardId()

Returns the shard id of this shard.

routingEntry

ShardRouting routingEntry()

Returns the latest cluster routing entry received with this shard.

state

IndexShardState state()

Returns the latest internal shard state.

recoveryState

RecoveryState recoveryState()

Returns the recovery state associated with this shard.

updateShardState

void updateShardState(ShardRouting shardRouting,
                      long primaryTerm,
                      java.util.function.BiConsumer<IndexShard,ActionListener<PrimaryReplicaSyncer.ResyncTask>> primaryReplicaSyncer,
                      long applyingClusterStateVersion,
                      java.util.Set<java.lang.String> inSyncAllocationIds,
                      IndexShardRoutingTable routingTable,
                      java.util.Set<java.lang.String> pre60AllocationIds)
               throws java.io.IOException

Updates the shard state based on an incoming cluster state: - Updates and persists the new routing value. - Updates the primary term if this shard is a primary. - Updates the allocation ids that are tracked by the shard if it is a primary. See GlobalCheckpointTracker.updateFromMaster(long, Set, IndexShardRoutingTable, Set) for details.

Parameters:

shardRouting - the new routing entry

primaryTerm - the new primary term

primaryReplicaSyncer - the primary-replica resync action to trigger when a term is increased on a primary

applyingClusterStateVersion - the cluster state version being applied when updating the allocation IDs from the master

inSyncAllocationIds - the allocation ids of the currently in-sync shard copies

routingTable - the shard routing table

Throws:

IndexShardRelocatedException - if shard is marked as relocated and relocation aborted

java.io.IOException - if shard state could not be persisted