org.elasticsearch.action.admin.indices.upgrade.get

Class TransportUpgradeStatusAction

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

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

org.elasticsearch.action.support.broadcast.TransportBroadcastOperationAction<UpgradeStatusRequest,UpgradeStatusResponse,org.elasticsearch.action.admin.indices.upgrade.get.TransportUpgradeStatusAction.IndexShardUpgradeStatusRequest,ShardUpgradeStatus>

org.elasticsearch.action.admin.indices.upgrade.get.TransportUpgradeStatusAction

public class TransportUpgradeStatusAction
extends TransportBroadcastOperationAction<UpgradeStatusRequest,UpgradeStatusResponse,org.elasticsearch.action.admin.indices.upgrade.get.TransportUpgradeStatusAction.IndexShardUpgradeStatusRequest,ShardUpgradeStatus>

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
TransportUpgradeStatusAction(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, UpgradeStatusRequest request)
protected ClusterBlockException	checkRequestBlock(ClusterState state, UpgradeStatusRequest countRequest, String[] concreteIndices)
protected String	executor()
protected UpgradeStatusRequest	newRequest()
protected UpgradeStatusResponse	newResponse(UpgradeStatusRequest request, AtomicReferenceArray shardsResponses, ClusterState clusterState)
protected org.elasticsearch.action.admin.indices.upgrade.get.TransportUpgradeStatusAction.IndexShardUpgradeStatusRequest	newShardRequest()
protected org.elasticsearch.action.admin.indices.upgrade.get.TransportUpgradeStatusAction.IndexShardUpgradeStatusRequest	newShardRequest(int numShards, ShardRouting shard, UpgradeStatusRequest request)
protected ShardUpgradeStatus	newShardResponse()
protected ShardUpgradeStatus	shardOperation(org.elasticsearch.action.admin.indices.upgrade.get.TransportUpgradeStatusAction.IndexShardUpgradeStatusRequest request)
protected GroupShardsIterator	shards(ClusterState clusterState, UpgradeStatusRequest request, String[] concreteIndices) Getting upgrade stats from *all* active shards.

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

TransportUpgradeStatusAction

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

Method Detail

shards

protected GroupShardsIterator shards(ClusterState clusterState,
                                     UpgradeStatusRequest request,
                                     String[] concreteIndices)

Getting upgrade stats from *all* active shards.

Specified by:

shards in class TransportBroadcastOperationAction<UpgradeStatusRequest,UpgradeStatusResponse,org.elasticsearch.action.admin.indices.upgrade.get.TransportUpgradeStatusAction.IndexShardUpgradeStatusRequest,ShardUpgradeStatus>

checkGlobalBlock

protected ClusterBlockException checkGlobalBlock(ClusterState state,
                                                 UpgradeStatusRequest request)

Specified by:

checkGlobalBlock in class TransportBroadcastOperationAction<UpgradeStatusRequest,UpgradeStatusResponse,org.elasticsearch.action.admin.indices.upgrade.get.TransportUpgradeStatusAction.IndexShardUpgradeStatusRequest,ShardUpgradeStatus>

checkRequestBlock

protected ClusterBlockException checkRequestBlock(ClusterState state,
                                                  UpgradeStatusRequest countRequest,
                                                  String[] concreteIndices)

Specified by:

checkRequestBlock in class TransportBroadcastOperationAction<UpgradeStatusRequest,UpgradeStatusResponse,org.elasticsearch.action.admin.indices.upgrade.get.TransportUpgradeStatusAction.IndexShardUpgradeStatusRequest,ShardUpgradeStatus>

executor

protected String executor()

Specified by:

executor in class TransportBroadcastOperationAction<UpgradeStatusRequest,UpgradeStatusResponse,org.elasticsearch.action.admin.indices.upgrade.get.TransportUpgradeStatusAction.IndexShardUpgradeStatusRequest,ShardUpgradeStatus>

newRequest

protected UpgradeStatusRequest newRequest()

Specified by:

newRequest in class TransportBroadcastOperationAction<UpgradeStatusRequest,UpgradeStatusResponse,org.elasticsearch.action.admin.indices.upgrade.get.TransportUpgradeStatusAction.IndexShardUpgradeStatusRequest,ShardUpgradeStatus>

newResponse

protected UpgradeStatusResponse newResponse(UpgradeStatusRequest request,
                                            AtomicReferenceArray shardsResponses,
                                            ClusterState clusterState)

Specified by:

newResponse in class TransportBroadcastOperationAction<UpgradeStatusRequest,UpgradeStatusResponse,org.elasticsearch.action.admin.indices.upgrade.get.TransportUpgradeStatusAction.IndexShardUpgradeStatusRequest,ShardUpgradeStatus>

newShardRequest

protected org.elasticsearch.action.admin.indices.upgrade.get.TransportUpgradeStatusAction.IndexShardUpgradeStatusRequest newShardRequest()

Specified by:

newShardRequest in class TransportBroadcastOperationAction<UpgradeStatusRequest,UpgradeStatusResponse,org.elasticsearch.action.admin.indices.upgrade.get.TransportUpgradeStatusAction.IndexShardUpgradeStatusRequest,ShardUpgradeStatus>

newShardRequest

protected org.elasticsearch.action.admin.indices.upgrade.get.TransportUpgradeStatusAction.IndexShardUpgradeStatusRequest newShardRequest(int numShards,
                                                                                                                                         ShardRouting shard,
                                                                                                                                         UpgradeStatusRequest request)

Specified by:

newShardRequest in class TransportBroadcastOperationAction<UpgradeStatusRequest,UpgradeStatusResponse,org.elasticsearch.action.admin.indices.upgrade.get.TransportUpgradeStatusAction.IndexShardUpgradeStatusRequest,ShardUpgradeStatus>

newShardResponse

protected ShardUpgradeStatus newShardResponse()

Specified by:

newShardResponse in class TransportBroadcastOperationAction<UpgradeStatusRequest,UpgradeStatusResponse,org.elasticsearch.action.admin.indices.upgrade.get.TransportUpgradeStatusAction.IndexShardUpgradeStatusRequest,ShardUpgradeStatus>

shardOperation

protected ShardUpgradeStatus shardOperation(org.elasticsearch.action.admin.indices.upgrade.get.TransportUpgradeStatusAction.IndexShardUpgradeStatusRequest request)

Specified by:

shardOperation in class TransportBroadcastOperationAction<UpgradeStatusRequest,UpgradeStatusResponse,org.elasticsearch.action.admin.indices.upgrade.get.TransportUpgradeStatusAction.IndexShardUpgradeStatusRequest,ShardUpgradeStatus>