public class TransportUpgradeAction extends TransportBroadcastOperationAction<UpgradeRequest,UpgradeResponse,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeRequest,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeResponse>
TransportBroadcastOperationAction.AsyncBroadcastAction
clusterService, threadPool, transportService
actionName
componentSettings, logger, settings
Constructor and Description |
---|
TransportUpgradeAction(Settings settings,
ThreadPool threadPool,
ClusterService clusterService,
TransportService transportService,
IndicesService indicesService,
ActionFilters actionFilters,
TransportUpgradeSettingsAction upgradeSettingsAction) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
checkGlobalBlock(ClusterState state,
UpgradeRequest request) |
protected ClusterBlockException |
checkRequestBlock(ClusterState state,
UpgradeRequest request,
String[] concreteIndices) |
protected void |
doExecute(UpgradeRequest request,
ActionListener<UpgradeResponse> listener) |
protected String |
executor() |
protected UpgradeRequest |
newRequest() |
protected UpgradeResponse |
newResponse(UpgradeRequest request,
AtomicReferenceArray shardsResponses,
ClusterState clusterState) |
protected org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeRequest |
newShardRequest() |
protected org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeRequest |
newShardRequest(int numShards,
ShardRouting shard,
UpgradeRequest request) |
protected org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeResponse |
newShardResponse() |
protected org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeResponse |
shardOperation(org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeRequest request) |
protected GroupShardsIterator |
shards(ClusterState clusterState,
UpgradeRequest request,
String[] concreteIndices)
The upgrade request works against *all* shards.
|
execute, execute, forceThreadedListener
nodeName
@Inject public TransportUpgradeAction(Settings settings, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, IndicesService indicesService, ActionFilters actionFilters, TransportUpgradeSettingsAction upgradeSettingsAction)
protected UpgradeResponse newResponse(UpgradeRequest request, AtomicReferenceArray shardsResponses, ClusterState clusterState)
newResponse
in class TransportBroadcastOperationAction<UpgradeRequest,UpgradeResponse,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeRequest,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeResponse>
protected org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeRequest newShardRequest()
newShardRequest
in class TransportBroadcastOperationAction<UpgradeRequest,UpgradeResponse,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeRequest,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeResponse>
protected org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeRequest newShardRequest(int numShards, ShardRouting shard, UpgradeRequest request)
newShardRequest
in class TransportBroadcastOperationAction<UpgradeRequest,UpgradeResponse,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeRequest,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeResponse>
protected org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeResponse newShardResponse()
newShardResponse
in class TransportBroadcastOperationAction<UpgradeRequest,UpgradeResponse,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeRequest,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeResponse>
protected org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeResponse shardOperation(org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeRequest request)
shardOperation
in class TransportBroadcastOperationAction<UpgradeRequest,UpgradeResponse,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeRequest,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeResponse>
protected GroupShardsIterator shards(ClusterState clusterState, UpgradeRequest request, String[] concreteIndices)
shards
in class TransportBroadcastOperationAction<UpgradeRequest,UpgradeResponse,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeRequest,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeResponse>
protected ClusterBlockException checkGlobalBlock(ClusterState state, UpgradeRequest request)
checkGlobalBlock
in class TransportBroadcastOperationAction<UpgradeRequest,UpgradeResponse,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeRequest,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeResponse>
protected ClusterBlockException checkRequestBlock(ClusterState state, UpgradeRequest request, String[] concreteIndices)
checkRequestBlock
in class TransportBroadcastOperationAction<UpgradeRequest,UpgradeResponse,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeRequest,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeResponse>
protected void doExecute(UpgradeRequest request, ActionListener<UpgradeResponse> listener)
doExecute
in class TransportBroadcastOperationAction<UpgradeRequest,UpgradeResponse,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeRequest,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeResponse>
protected String executor()
executor
in class TransportBroadcastOperationAction<UpgradeRequest,UpgradeResponse,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeRequest,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeResponse>
protected UpgradeRequest newRequest()
newRequest
in class TransportBroadcastOperationAction<UpgradeRequest,UpgradeResponse,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeRequest,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeResponse>
Copyright © 2009–2016. All rights reserved.