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, transportNodeAction, transportService
Fields inherited from class org.elasticsearch.action.support.TransportAction
actionName, localConnection, logger, taskManager
-
Constructor Summary
Constructors Constructor Description TransportNodesListShardStoreMetadata(Settings settings, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, IndicesService indicesService, NodeEnvironment nodeEnv, ActionFilters actionFilters)
-
Method Summary
Modifier and Type Method Description void
list(ShardId shardId, java.lang.String customDataPath, 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 newTransportNodesAction
(multi-node response).protected TransportNodesListShardStoreMetadata.NodeStoreFilesMetadata
nodeOperation(TransportNodesListShardStoreMetadata.NodeRequest 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
-
Field Details
-
ACTION_NAME
public static final java.lang.String ACTION_NAME- See Also:
- Constant Field Values
-
TYPE
-
-
Constructor Details
-
TransportNodesListShardStoreMetadata
@Inject public TransportNodesListShardStoreMetadata(Settings settings, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, IndicesService indicesService, NodeEnvironment nodeEnv, ActionFilters actionFilters)
-
-
Method Details
-
list
public void list(ShardId shardId, java.lang.String customDataPath, DiscoveryNode[] nodes, ActionListener<TransportNodesListShardStoreMetadata.NodesStoreFilesMetadata> listener) -
newNodeRequest
protected TransportNodesListShardStoreMetadata.NodeRequest newNodeRequest(TransportNodesListShardStoreMetadata.Request request) -
newNodeResponse
protected TransportNodesListShardStoreMetadata.NodeStoreFilesMetadata newNodeResponse(StreamInput in) throws java.io.IOException- Specified by:
newNodeResponse
in classTransportNodesAction<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 newTransportNodesAction
(multi-node response).- Specified by:
newResponse
in classTransportNodesAction<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)
-