public class TransportUpdateAction extends TransportInstanceSingleOperationAction<UpdateRequest,UpdateResponse>
TransportInstanceSingleOperationAction.InternalRequest
clusterService, transportService
actionName, threadPool
componentSettings, logger, settings
Constructor and Description |
---|
TransportUpdateAction(Settings settings,
ThreadPool threadPool,
ClusterService clusterService,
TransportService transportService,
TransportIndexAction indexAction,
TransportDeleteAction deleteAction,
TransportCreateIndexAction createIndexAction,
UpdateHelper updateHelper,
ActionFilters actionFilters,
IndicesService indicesService) |
Modifier and Type | Method and Description |
---|---|
protected void |
doExecute(UpdateRequest request,
ActionListener<UpdateResponse> listener) |
protected String |
executor() |
protected UpdateRequest |
newRequest() |
protected UpdateResponse |
newResponse() |
protected boolean |
resolveRequest(ClusterState state,
TransportInstanceSingleOperationAction.InternalRequest request,
ActionListener<UpdateResponse> listener)
Resolves the request.
|
protected boolean |
retryOnFailure(Throwable e) |
protected void |
shardOperation(TransportInstanceSingleOperationAction.InternalRequest request,
ActionListener<UpdateResponse> listener) |
protected void |
shardOperation(TransportInstanceSingleOperationAction.InternalRequest request,
ActionListener<UpdateResponse> listener,
int retryCount) |
protected ShardIterator |
shards(ClusterState clusterState,
TransportInstanceSingleOperationAction.InternalRequest request)
Should return an iterator with a single shard!
|
checkGlobalBlock, checkRequestBlock, transportOptions
execute, execute, forceThreadedListener
nodeName
@Inject public TransportUpdateAction(Settings settings, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, TransportIndexAction indexAction, TransportDeleteAction deleteAction, TransportCreateIndexAction createIndexAction, UpdateHelper updateHelper, ActionFilters actionFilters, IndicesService indicesService)
protected String executor()
executor
in class TransportInstanceSingleOperationAction<UpdateRequest,UpdateResponse>
protected UpdateRequest newRequest()
newRequest
in class TransportInstanceSingleOperationAction<UpdateRequest,UpdateResponse>
protected UpdateResponse newResponse()
newResponse
in class TransportInstanceSingleOperationAction<UpdateRequest,UpdateResponse>
protected boolean retryOnFailure(Throwable e)
retryOnFailure
in class TransportInstanceSingleOperationAction<UpdateRequest,UpdateResponse>
protected boolean resolveRequest(ClusterState state, TransportInstanceSingleOperationAction.InternalRequest request, ActionListener<UpdateResponse> listener)
TransportInstanceSingleOperationAction
resolveRequest
in class TransportInstanceSingleOperationAction<UpdateRequest,UpdateResponse>
protected void doExecute(UpdateRequest request, ActionListener<UpdateResponse> listener)
doExecute
in class TransportInstanceSingleOperationAction<UpdateRequest,UpdateResponse>
protected ShardIterator shards(ClusterState clusterState, TransportInstanceSingleOperationAction.InternalRequest request) throws ElasticsearchException
TransportInstanceSingleOperationAction
shards
in class TransportInstanceSingleOperationAction<UpdateRequest,UpdateResponse>
ElasticsearchException
protected void shardOperation(TransportInstanceSingleOperationAction.InternalRequest request, ActionListener<UpdateResponse> listener) throws ElasticsearchException
shardOperation
in class TransportInstanceSingleOperationAction<UpdateRequest,UpdateResponse>
ElasticsearchException
protected void shardOperation(TransportInstanceSingleOperationAction.InternalRequest request, ActionListener<UpdateResponse> listener, int retryCount) throws ElasticsearchException
ElasticsearchException
Copyright © 2009–2015. All rights reserved.