Package org.elasticsearch.indices.store

Class TransportNodesListShardStoreMetaData

java.lang.Object

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

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

org.elasticsearch.action.support.nodes.TransportNodesAction<TransportNodesListShardStoreMetaData.Request,TransportNodesListShardStoreMetaData.NodesStoreFilesMetaData,TransportNodesListShardStoreMetaData.NodeRequest,TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData>

org.elasticsearch.indices.store.TransportNodesListShardStoreMetaData

All Implemented Interfaces:

AsyncShardFetch.Lister<TransportNodesListShardStoreMetaData.NodesStoreFilesMetaData,TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData>

public class TransportNodesListShardStoreMetaData
extends TransportNodesAction<TransportNodesListShardStoreMetaData.Request,TransportNodesListShardStoreMetaData.NodesStoreFilesMetaData,TransportNodesListShardStoreMetaData.NodeRequest,TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData>
implements AsyncShardFetch.Lister<TransportNodesListShardStoreMetaData.NodesStoreFilesMetaData,TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TransportNodesListShardStoreMetaData.NodeRequest
static class	TransportNodesListShardStoreMetaData.NodesStoreFilesMetaData
static class	TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData
static class	TransportNodesListShardStoreMetaData.Request
static class	TransportNodesListShardStoreMetaData.StoreFilesMetaData

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	ACTION_NAME
static ActionType<TransportNodesListShardStoreMetaData.NodesStoreFilesMetaData>	TYPE

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

clusterService, nodeResponseClass, threadPool, transportService

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

actionName, logger, taskManager

Constructor Summary

Constructors

Constructor	Description
TransportNodesListShardStoreMetaData(Settings settings, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, IndicesService indicesService, NodeEnvironment nodeEnv, ActionFilters actionFilters, NamedXContentRegistry namedXContentRegistry)

Method Summary

Modifier and Type	Method	Description
void	list(ShardId shardId, DiscoveryNode[] nodes, ActionListener<TransportNodesListShardStoreMetaData.NodesStoreFilesMetaData> listener)
protected TransportNodesListShardStoreMetaData.NodeRequest	newNodeRequest(TransportNodesListShardStoreMetaData.Request request)
protected TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData	newNodeResponse(StreamInput in)
protected TransportNodesListShardStoreMetaData.NodesStoreFilesMetaData	newResponse(TransportNodesListShardStoreMetaData.Request request, java.util.List<TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData> responses, java.util.List<FailedNodeException> failures)	Create a new TransportNodesAction (multi-node response).
protected TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData	nodeOperation(TransportNodesListShardStoreMetaData.NodeRequest request)

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

doExecute, newResponse, 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

Field Detail

ACTION_NAME

public static final java.lang.String ACTION_NAME

See Also:

Constant Field Values

TYPE

public static final ActionType<TransportNodesListShardStoreMetaData.NodesStoreFilesMetaData> TYPE

Constructor Detail

TransportNodesListShardStoreMetaData

@Inject
public TransportNodesListShardStoreMetaData(Settings settings,
                                            ThreadPool threadPool,
                                            ClusterService clusterService,
                                            TransportService transportService,
                                            IndicesService indicesService,
                                            NodeEnvironment nodeEnv,
                                            ActionFilters actionFilters,
                                            NamedXContentRegistry namedXContentRegistry)

Method Detail

list

public void list(ShardId shardId,
                 DiscoveryNode[] nodes,
                 ActionListener<TransportNodesListShardStoreMetaData.NodesStoreFilesMetaData> listener)

Specified by:

list in interface AsyncShardFetch.Lister<TransportNodesListShardStoreMetaData.NodesStoreFilesMetaData,TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData>

newNodeRequest

protected TransportNodesListShardStoreMetaData.NodeRequest newNodeRequest(TransportNodesListShardStoreMetaData.Request request)

Specified by:

newNodeRequest in class TransportNodesAction<TransportNodesListShardStoreMetaData.Request,TransportNodesListShardStoreMetaData.NodesStoreFilesMetaData,TransportNodesListShardStoreMetaData.NodeRequest,TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData>

newNodeResponse

protected TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData newNodeResponse(StreamInput in)
                                                                               throws java.io.IOException

Specified by:

newNodeResponse in class TransportNodesAction<TransportNodesListShardStoreMetaData.Request,TransportNodesListShardStoreMetaData.NodesStoreFilesMetaData,TransportNodesListShardStoreMetaData.NodeRequest,TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData>

Throws:

java.io.IOException

newResponse

protected TransportNodesListShardStoreMetaData.NodesStoreFilesMetaData newResponse(TransportNodesListShardStoreMetaData.Request request,
                                                                                   java.util.List<TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData> responses,
                                                                                   java.util.List<FailedNodeException> failures)

Description copied from class: TransportNodesAction

Create a new TransportNodesAction (multi-node response).

Specified by:

newResponse in class TransportNodesAction<TransportNodesListShardStoreMetaData.Request,TransportNodesListShardStoreMetaData.NodesStoreFilesMetaData,TransportNodesListShardStoreMetaData.NodeRequest,TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData>

Parameters:

request - The associated request.

responses - All successful node-level responses.

failures - All node-level failures.

Returns:

Never null.

nodeOperation

protected TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData nodeOperation(TransportNodesListShardStoreMetaData.NodeRequest request)

Specified by:

nodeOperation in class TransportNodesAction<TransportNodesListShardStoreMetaData.Request,TransportNodesListShardStoreMetaData.NodesStoreFilesMetaData,TransportNodesListShardStoreMetaData.NodeRequest,TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData>