Package org.elasticsearch.action.admin.indices.dangling.list

Class TransportListDanglingIndicesAction

java.lang.Object

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

org.elasticsearch.action.support.HandledTransportAction<NodesRequest,NodesResponse>

org.elasticsearch.action.support.nodes.TransportNodesAction<ListDanglingIndicesRequest,ListDanglingIndicesResponse,NodeListDanglingIndicesRequest,NodeListDanglingIndicesResponse>

org.elasticsearch.action.admin.indices.dangling.list.TransportListDanglingIndicesAction

public class TransportListDanglingIndicesAction
extends TransportNodesAction<ListDanglingIndicesRequest,ListDanglingIndicesResponse,NodeListDanglingIndicesRequest,NodeListDanglingIndicesResponse>

Implements the listing of all dangling indices. All nodes in the cluster are queried, and their answers aggregated. Finding dangling indices is performed in DanglingIndicesState.

Field Summary

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

clusterService, nodeResponseClass, threadPool, transportNodeAction

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

actionName, localConnection, logger, taskManager

Constructor Summary

Constructors

Constructor	Description
TransportListDanglingIndicesAction(ThreadPool threadPool, ClusterService clusterService, TransportService transportService, ActionFilters actionFilters, DanglingIndicesState danglingIndicesState)

Method Summary

Modifier and Type	Method	Description
protected NodeListDanglingIndicesRequest	newNodeRequest(ListDanglingIndicesRequest request)
protected NodeListDanglingIndicesResponse	newNodeResponse(StreamInput in)
protected ListDanglingIndicesResponse	newResponse(ListDanglingIndicesRequest request, List<NodeListDanglingIndicesResponse> nodeListDanglingIndicesResponse, List<FailedNodeException> failures)	Create a new TransportNodesAction (multi-node response).
protected NodeListDanglingIndicesResponse	nodeOperation(NodeListDanglingIndicesRequest request)

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

doExecute, getTransportNodeAction, newResponseAsync, nodeOperation, resolveRequest

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

execute, execute, execute

Methods inherited from class java.lang.Object

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

Constructor Details

TransportListDanglingIndicesAction

@Inject
public TransportListDanglingIndicesAction(ThreadPool threadPool,
 ClusterService clusterService,
 TransportService transportService,
 ActionFilters actionFilters,
 DanglingIndicesState danglingIndicesState)

Method Details

newResponse

protected ListDanglingIndicesResponse newResponse(ListDanglingIndicesRequest request,
 List<NodeListDanglingIndicesResponse> nodeListDanglingIndicesResponse,
 List<FailedNodeException> failures)

Description copied from class: TransportNodesAction

Create a new TransportNodesAction (multi-node response).

Specified by:

newResponse in class TransportNodesAction<ListDanglingIndicesRequest,ListDanglingIndicesResponse,NodeListDanglingIndicesRequest,NodeListDanglingIndicesResponse>

Parameters:

request - The associated request.

nodeListDanglingIndicesResponse - All successful node-level responses.

failures - All node-level failures.

Returns:

Never null.

newNodeRequest

protected NodeListDanglingIndicesRequest newNodeRequest(ListDanglingIndicesRequest request)

Specified by:

newNodeRequest in class TransportNodesAction<ListDanglingIndicesRequest,ListDanglingIndicesResponse,NodeListDanglingIndicesRequest,NodeListDanglingIndicesResponse>

newNodeResponse

protected NodeListDanglingIndicesResponse newNodeResponse(StreamInput in)
                                                   throws IOException

Specified by:

newNodeResponse in class TransportNodesAction<ListDanglingIndicesRequest,ListDanglingIndicesResponse,NodeListDanglingIndicesRequest,NodeListDanglingIndicesResponse>

Throws:

IOException

nodeOperation

protected NodeListDanglingIndicesResponse nodeOperation(NodeListDanglingIndicesRequest request)

Specified by:

nodeOperation in class TransportNodesAction<ListDanglingIndicesRequest,ListDanglingIndicesResponse,NodeListDanglingIndicesRequest,NodeListDanglingIndicesResponse>