Module org.elasticsearch.server

Package org.elasticsearch.action.admin.cluster.state

Class TransportAwaitClusterStateVersionAppliedAction

java.lang.Object

org.elasticsearch.action.support.TransportAction<AwaitClusterStateVersionAppliedRequest,AwaitClusterStateVersionAppliedResponse>

org.elasticsearch.action.support.nodes.TransportNodesAction<AwaitClusterStateVersionAppliedRequest,AwaitClusterStateVersionAppliedResponse,TransportAwaitClusterStateVersionAppliedAction.NodeRequest,TransportAwaitClusterStateVersionAppliedAction.NodeResponse,Void>

org.elasticsearch.action.admin.cluster.state.TransportAwaitClusterStateVersionAppliedAction

public class TransportAwaitClusterStateVersionAppliedAction
extends TransportNodesAction<AwaitClusterStateVersionAppliedRequest,AwaitClusterStateVersionAppliedResponse,TransportAwaitClusterStateVersionAppliedAction.NodeRequest,TransportAwaitClusterStateVersionAppliedAction.NodeResponse,Void>

An action that waits for a given cluster state version to be applied on provided set of nodes in the cluster.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TransportAwaitClusterStateVersionAppliedAction.NodeRequest
static class	TransportAwaitClusterStateVersionAppliedAction.NodeResponse

Field Summary

Fields

Modifier and Type	Field	Description
static final ActionType<AwaitClusterStateVersionAppliedResponse>	TYPE

Fields inherited from class org.elasticsearch.action.support.nodes.TransportNodesAction

clusterService, transportNodeAction, transportService

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

actionName, taskManager

Constructor Summary

Constructors

Constructor	Description
TransportAwaitClusterStateVersionAppliedAction(ClusterService clusterService, TransportService transportService, ActionFilters actionFilters, ThreadPool threadPool)

Method Summary

Modifier and Type	Method	Description
protected TransportAwaitClusterStateVersionAppliedAction.NodeRequest	newNodeRequest(AwaitClusterStateVersionAppliedRequest request)
protected TransportAwaitClusterStateVersionAppliedAction.NodeResponse	newNodeResponse(StreamInput in, DiscoveryNode node)
protected AwaitClusterStateVersionAppliedResponse	newResponse(AwaitClusterStateVersionAppliedRequest request, List<TransportAwaitClusterStateVersionAppliedAction.NodeResponse> nodeResponses, List<FailedNodeException> failures)	Create a new TransportNodesAction.
protected TransportAwaitClusterStateVersionAppliedAction.NodeResponse	nodeOperation(TransportAwaitClusterStateVersionAppliedAction.NodeRequest request, Task task)	Implements the request recipient logic.
protected void	nodeOperationAsync(TransportAwaitClusterStateVersionAppliedAction.NodeRequest request, Task task, ActionListener<TransportAwaitClusterStateVersionAppliedAction.NodeResponse> listener)	This method can be overridden if a subclass needs to access to a listener in order to asynchronously respond to the node request.

Methods inherited from class org.elasticsearch.action.support.nodes.TransportNodesAction

createActionContext, doExecute, newResponseAsync, resolveRequest

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

execute, executeDirect, localOnly

Methods inherited from class java.lang.Object

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

Field Details

TYPE

public static final ActionType<AwaitClusterStateVersionAppliedResponse> TYPE

Constructor Details

TransportAwaitClusterStateVersionAppliedAction

@Inject
public TransportAwaitClusterStateVersionAppliedAction(ClusterService clusterService,
 TransportService transportService,
 ActionFilters actionFilters,
 ThreadPool threadPool)

Method Details

newResponse

protected AwaitClusterStateVersionAppliedResponse newResponse(AwaitClusterStateVersionAppliedRequest request,
 List<TransportAwaitClusterStateVersionAppliedAction.NodeResponse> nodeResponses,
 List<FailedNodeException> failures)

Description copied from class: TransportNodesAction

Create a new TransportNodesAction. This method is executed on TransportNodesAction.finalExecutor.

Specified by:

newResponse in class TransportNodesAction<AwaitClusterStateVersionAppliedRequest,AwaitClusterStateVersionAppliedResponse,TransportAwaitClusterStateVersionAppliedAction.NodeRequest,TransportAwaitClusterStateVersionAppliedAction.NodeResponse,Void>

Parameters:

request - The request whose response we are constructing. TransportNodesAction may have already released all its references to this object before calling this method, so it's up to individual implementations to retain their own reference to the request if still needed here.

nodeResponses - All successful node-level responses.

failures - All node-level failures.

Returns:

Never null.

newNodeRequest

protected TransportAwaitClusterStateVersionAppliedAction.NodeRequest newNodeRequest(AwaitClusterStateVersionAppliedRequest request)

Specified by:

newNodeRequest in class TransportNodesAction<AwaitClusterStateVersionAppliedRequest,AwaitClusterStateVersionAppliedResponse,TransportAwaitClusterStateVersionAppliedAction.NodeRequest,TransportAwaitClusterStateVersionAppliedAction.NodeResponse,Void>

newNodeResponse

protected TransportAwaitClusterStateVersionAppliedAction.NodeResponse newNodeResponse(StreamInput in,
 DiscoveryNode node)
                                                                               throws IOException

Specified by:

newNodeResponse in class TransportNodesAction<AwaitClusterStateVersionAppliedRequest,AwaitClusterStateVersionAppliedResponse,TransportAwaitClusterStateVersionAppliedAction.NodeRequest,TransportAwaitClusterStateVersionAppliedAction.NodeResponse,Void>

Throws:

IOException

nodeOperation

protected TransportAwaitClusterStateVersionAppliedAction.NodeResponse nodeOperation(TransportAwaitClusterStateVersionAppliedAction.NodeRequest request,
 Task task)

Description copied from class: TransportNodesAction

Implements the request recipient logic. If access to the request listener is needed, override TransportNodesAction.nodeOperationAsync(TransportRequest, Task, ActionListener).

Specified by:

nodeOperation in class TransportNodesAction<AwaitClusterStateVersionAppliedRequest,AwaitClusterStateVersionAppliedResponse,TransportAwaitClusterStateVersionAppliedAction.NodeRequest,TransportAwaitClusterStateVersionAppliedAction.NodeResponse,Void>

nodeOperationAsync

protected void nodeOperationAsync(TransportAwaitClusterStateVersionAppliedAction.NodeRequest request,
 Task task,
 ActionListener<TransportAwaitClusterStateVersionAppliedAction.NodeResponse> listener)

Description copied from class: TransportNodesAction

This method can be overridden if a subclass needs to access to a listener in order to asynchronously respond to the node request. The default implementation is to fall through to TransportNodesAction.nodeOperation(NodeRequest, org.elasticsearch.tasks.Task).

Overrides:

nodeOperationAsync in class TransportNodesAction<AwaitClusterStateVersionAppliedRequest,AwaitClusterStateVersionAppliedResponse,TransportAwaitClusterStateVersionAppliedAction.NodeRequest,TransportAwaitClusterStateVersionAppliedAction.NodeResponse,Void>