org.elasticsearch.action.admin.indices.recovery

Class TransportRecoveryAction

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.elasticsearch.action.support.TransportAction<Request,Response>

org.elasticsearch.action.support.broadcast.TransportBroadcastOperationAction<RecoveryRequest,RecoveryResponse,org.elasticsearch.action.admin.indices.recovery.TransportRecoveryAction.ShardRecoveryRequest,ShardRecoveryResponse>

org.elasticsearch.action.admin.indices.recovery.TransportRecoveryAction

public class TransportRecoveryAction
extends TransportBroadcastOperationAction<RecoveryRequest,RecoveryResponse,org.elasticsearch.action.admin.indices.recovery.TransportRecoveryAction.ShardRecoveryRequest,ShardRecoveryResponse>

Transport action for shard recovery operation. This transport action does not actually perform shard recovery, it only reports on recoveries (both active and complete).

Nested Class Summary

Nested classes/interfaces inherited from class org.elasticsearch.action.support.broadcast.TransportBroadcastOperationAction

TransportBroadcastOperationAction.AsyncBroadcastAction

Field Summary

Fields inherited from class org.elasticsearch.action.support.broadcast.TransportBroadcastOperationAction

clusterService, threadPool, transportService

Fields inherited from class org.elasticsearch.action.support.TransportAction

actionName

Fields inherited from class org.elasticsearch.common.component.AbstractComponent

componentSettings, logger, settings

Constructor Summary

Constructors

Constructor and Description
TransportRecoveryAction(Settings settings, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, IndicesService indicesService, ActionFilters actionFilters)

Method Summary

Modifier and Type	Method and Description
protected ClusterBlockException	checkGlobalBlock(ClusterState state, RecoveryRequest request)
protected ClusterBlockException	checkRequestBlock(ClusterState state, RecoveryRequest request, String[] concreteIndices)
protected String	executor()
protected RecoveryRequest	newRequest()
protected RecoveryResponse	newResponse(RecoveryRequest request, AtomicReferenceArray shardsResponses, ClusterState clusterState)
protected org.elasticsearch.action.admin.indices.recovery.TransportRecoveryAction.ShardRecoveryRequest	newShardRequest()
protected org.elasticsearch.action.admin.indices.recovery.TransportRecoveryAction.ShardRecoveryRequest	newShardRequest(int numShards, ShardRouting shard, RecoveryRequest request)
protected ShardRecoveryResponse	newShardResponse()
protected ShardRecoveryResponse	shardOperation(org.elasticsearch.action.admin.indices.recovery.TransportRecoveryAction.ShardRecoveryRequest request)
protected GroupShardsIterator	shards(ClusterState state, RecoveryRequest request, String[] concreteIndices) Determines the shards this operation will be executed on.

Methods inherited from class org.elasticsearch.action.support.broadcast.TransportBroadcastOperationAction

doExecute

Methods inherited from class org.elasticsearch.action.support.TransportAction

execute, execute, forceThreadedListener

Methods inherited from class org.elasticsearch.common.component.AbstractComponent

nodeName

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TransportRecoveryAction

@Inject
public TransportRecoveryAction(Settings settings,
                                       ThreadPool threadPool,
                                       ClusterService clusterService,
                                       TransportService transportService,
                                       IndicesService indicesService,
                                       ActionFilters actionFilters)

Method Detail

executor

protected String executor()

Specified by:

executor in class TransportBroadcastOperationAction<RecoveryRequest,RecoveryResponse,org.elasticsearch.action.admin.indices.recovery.TransportRecoveryAction.ShardRecoveryRequest,ShardRecoveryResponse>

newRequest

protected RecoveryRequest newRequest()

Specified by:

newRequest in class TransportBroadcastOperationAction<RecoveryRequest,RecoveryResponse,org.elasticsearch.action.admin.indices.recovery.TransportRecoveryAction.ShardRecoveryRequest,ShardRecoveryResponse>

newResponse

protected RecoveryResponse newResponse(RecoveryRequest request,
                                       AtomicReferenceArray shardsResponses,
                                       ClusterState clusterState)

Specified by:

newResponse in class TransportBroadcastOperationAction<RecoveryRequest,RecoveryResponse,org.elasticsearch.action.admin.indices.recovery.TransportRecoveryAction.ShardRecoveryRequest,ShardRecoveryResponse>

newShardRequest

protected org.elasticsearch.action.admin.indices.recovery.TransportRecoveryAction.ShardRecoveryRequest newShardRequest()

Specified by:

newShardRequest in class TransportBroadcastOperationAction<RecoveryRequest,RecoveryResponse,org.elasticsearch.action.admin.indices.recovery.TransportRecoveryAction.ShardRecoveryRequest,ShardRecoveryResponse>

newShardRequest

protected org.elasticsearch.action.admin.indices.recovery.TransportRecoveryAction.ShardRecoveryRequest newShardRequest(int numShards,
                                                                                                                       ShardRouting shard,
                                                                                                                       RecoveryRequest request)

Specified by:

newShardRequest in class TransportBroadcastOperationAction<RecoveryRequest,RecoveryResponse,org.elasticsearch.action.admin.indices.recovery.TransportRecoveryAction.ShardRecoveryRequest,ShardRecoveryResponse>

newShardResponse

protected ShardRecoveryResponse newShardResponse()

Specified by:

newShardResponse in class TransportBroadcastOperationAction<RecoveryRequest,RecoveryResponse,org.elasticsearch.action.admin.indices.recovery.TransportRecoveryAction.ShardRecoveryRequest,ShardRecoveryResponse>

shardOperation

protected ShardRecoveryResponse shardOperation(org.elasticsearch.action.admin.indices.recovery.TransportRecoveryAction.ShardRecoveryRequest request)
                                        throws ElasticsearchException

Specified by:

shardOperation in class TransportBroadcastOperationAction<RecoveryRequest,RecoveryResponse,org.elasticsearch.action.admin.indices.recovery.TransportRecoveryAction.ShardRecoveryRequest,ShardRecoveryResponse>

Throws:

ElasticsearchException

shards

protected GroupShardsIterator shards(ClusterState state,
                                     RecoveryRequest request,
                                     String[] concreteIndices)

Description copied from class: TransportBroadcastOperationAction

Determines the shards this operation will be executed on. The operation is executed once per shard iterator, typically on the first shard in it. If the operation fails, it will be retried on the next shard in the iterator.

Specified by:

shards in class TransportBroadcastOperationAction<RecoveryRequest,RecoveryResponse,org.elasticsearch.action.admin.indices.recovery.TransportRecoveryAction.ShardRecoveryRequest,ShardRecoveryResponse>

checkGlobalBlock

protected ClusterBlockException checkGlobalBlock(ClusterState state,
                                                 RecoveryRequest request)

Specified by:

checkGlobalBlock in class TransportBroadcastOperationAction<RecoveryRequest,RecoveryResponse,org.elasticsearch.action.admin.indices.recovery.TransportRecoveryAction.ShardRecoveryRequest,ShardRecoveryResponse>

checkRequestBlock

protected ClusterBlockException checkRequestBlock(ClusterState state,
                                                  RecoveryRequest request,
                                                  String[] concreteIndices)

Specified by:

checkRequestBlock in class TransportBroadcastOperationAction<RecoveryRequest,RecoveryResponse,org.elasticsearch.action.admin.indices.recovery.TransportRecoveryAction.ShardRecoveryRequest,ShardRecoveryResponse>