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>
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 |
Modifier and Type | Field | Description |
---|---|---|
static java.lang.String |
ACTION_NAME |
deprecationLogger, logger, settings
actionName, indexNameExpressionResolver, taskManager, threadPool
clusterService, nodeResponseClass, transportService
Constructor | Description |
---|---|
TransportNodesListShardStoreMetaData(Settings settings,
ThreadPool threadPool,
ClusterService clusterService,
TransportService transportService,
IndicesService indicesService,
NodeEnvironment nodeEnv,
ActionFilters actionFilters,
IndexNameExpressionResolver indexNameExpressionResolver) |
Modifier and Type | Method | Description |
---|---|---|
void |
list(ShardId shardId,
DiscoveryNode[] nodes,
ActionListener<TransportNodesListShardStoreMetaData.NodesStoreFilesMetaData> listener) |
|
protected TransportNodesListShardStoreMetaData.NodeRequest |
newNodeRequest(java.lang.String nodeId,
TransportNodesListShardStoreMetaData.Request request) |
|
protected TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData |
newNodeResponse() |
|
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) |
logDeprecatedSetting, logRemovedSetting, nodeName
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
execute, execute, execute, execute
doExecute, doExecute, newResponse, nodeOperation, resolveRequest, transportCompress
public static final java.lang.String ACTION_NAME
@Inject public TransportNodesListShardStoreMetaData(Settings settings, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, IndicesService indicesService, NodeEnvironment nodeEnv, ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver)
public void list(ShardId shardId, DiscoveryNode[] nodes, ActionListener<TransportNodesListShardStoreMetaData.NodesStoreFilesMetaData> listener)
protected TransportNodesListShardStoreMetaData.NodeRequest newNodeRequest(java.lang.String nodeId, TransportNodesListShardStoreMetaData.Request request)
protected TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData newNodeResponse()
protected TransportNodesListShardStoreMetaData.NodesStoreFilesMetaData newResponse(TransportNodesListShardStoreMetaData.Request request, java.util.List<TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData> responses, java.util.List<FailedNodeException> failures)
TransportNodesAction
TransportNodesAction
(multi-node response).newResponse
in class TransportNodesAction<TransportNodesListShardStoreMetaData.Request,TransportNodesListShardStoreMetaData.NodesStoreFilesMetaData,TransportNodesListShardStoreMetaData.NodeRequest,TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData>
request
- The associated request.responses
- All successful node-level responses.failures
- All node-level failures.null
.protected TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData nodeOperation(TransportNodesListShardStoreMetaData.NodeRequest request)