public class TransportNodesListShardStoreMetaData extends TransportNodesOperationAction<org.elasticsearch.indices.store.TransportNodesListShardStoreMetaData.Request,TransportNodesListShardStoreMetaData.NodesStoreFilesMetaData,org.elasticsearch.indices.store.TransportNodesListShardStoreMetaData.NodeRequest,TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData>
Modifier and Type | Class and Description |
---|---|
static class |
TransportNodesListShardStoreMetaData.NodesStoreFilesMetaData |
static class |
TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData |
static class |
TransportNodesListShardStoreMetaData.StoreFilesMetaData |
Modifier and Type | Field and Description |
---|---|
static String |
ACTION_NAME |
clusterName, clusterService, transportService
actionName, threadPool
componentSettings, logger, settings
Constructor and Description |
---|
TransportNodesListShardStoreMetaData(Settings settings,
ClusterName clusterName,
ThreadPool threadPool,
ClusterService clusterService,
TransportService transportService,
IndicesService indicesService,
NodeEnvironment nodeEnv,
ActionFilters actionFilters) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
accumulateExceptions() |
protected String |
executor() |
ActionFuture<TransportNodesListShardStoreMetaData.NodesStoreFilesMetaData> |
list(ShardId shardId,
boolean onlyUnallocated,
String[] nodesIds,
TimeValue timeout) |
protected org.elasticsearch.indices.store.TransportNodesListShardStoreMetaData.NodeRequest |
newNodeRequest() |
protected org.elasticsearch.indices.store.TransportNodesListShardStoreMetaData.NodeRequest |
newNodeRequest(String nodeId,
org.elasticsearch.indices.store.TransportNodesListShardStoreMetaData.Request request) |
protected TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData |
newNodeResponse() |
protected org.elasticsearch.indices.store.TransportNodesListShardStoreMetaData.Request |
newRequest() |
protected TransportNodesListShardStoreMetaData.NodesStoreFilesMetaData |
newResponse(org.elasticsearch.indices.store.TransportNodesListShardStoreMetaData.Request request,
AtomicReferenceArray responses) |
protected TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData |
nodeOperation(org.elasticsearch.indices.store.TransportNodesListShardStoreMetaData.NodeRequest request) |
doExecute, filterNodeIds, transportCompress
execute, execute, forceThreadedListener
nodeName
public static final String ACTION_NAME
@Inject public TransportNodesListShardStoreMetaData(Settings settings, ClusterName clusterName, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, IndicesService indicesService, NodeEnvironment nodeEnv, ActionFilters actionFilters)
public ActionFuture<TransportNodesListShardStoreMetaData.NodesStoreFilesMetaData> list(ShardId shardId, boolean onlyUnallocated, String[] nodesIds, @Nullable TimeValue timeout)
protected String executor()
executor
in class TransportNodesOperationAction<org.elasticsearch.indices.store.TransportNodesListShardStoreMetaData.Request,TransportNodesListShardStoreMetaData.NodesStoreFilesMetaData,org.elasticsearch.indices.store.TransportNodesListShardStoreMetaData.NodeRequest,TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData>
protected org.elasticsearch.indices.store.TransportNodesListShardStoreMetaData.Request newRequest()
newRequest
in class TransportNodesOperationAction<org.elasticsearch.indices.store.TransportNodesListShardStoreMetaData.Request,TransportNodesListShardStoreMetaData.NodesStoreFilesMetaData,org.elasticsearch.indices.store.TransportNodesListShardStoreMetaData.NodeRequest,TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData>
protected org.elasticsearch.indices.store.TransportNodesListShardStoreMetaData.NodeRequest newNodeRequest()
newNodeRequest
in class TransportNodesOperationAction<org.elasticsearch.indices.store.TransportNodesListShardStoreMetaData.Request,TransportNodesListShardStoreMetaData.NodesStoreFilesMetaData,org.elasticsearch.indices.store.TransportNodesListShardStoreMetaData.NodeRequest,TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData>
protected org.elasticsearch.indices.store.TransportNodesListShardStoreMetaData.NodeRequest newNodeRequest(String nodeId, org.elasticsearch.indices.store.TransportNodesListShardStoreMetaData.Request request)
newNodeRequest
in class TransportNodesOperationAction<org.elasticsearch.indices.store.TransportNodesListShardStoreMetaData.Request,TransportNodesListShardStoreMetaData.NodesStoreFilesMetaData,org.elasticsearch.indices.store.TransportNodesListShardStoreMetaData.NodeRequest,TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData>
protected TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData newNodeResponse()
newNodeResponse
in class TransportNodesOperationAction<org.elasticsearch.indices.store.TransportNodesListShardStoreMetaData.Request,TransportNodesListShardStoreMetaData.NodesStoreFilesMetaData,org.elasticsearch.indices.store.TransportNodesListShardStoreMetaData.NodeRequest,TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData>
protected TransportNodesListShardStoreMetaData.NodesStoreFilesMetaData newResponse(org.elasticsearch.indices.store.TransportNodesListShardStoreMetaData.Request request, AtomicReferenceArray responses)
newResponse
in class TransportNodesOperationAction<org.elasticsearch.indices.store.TransportNodesListShardStoreMetaData.Request,TransportNodesListShardStoreMetaData.NodesStoreFilesMetaData,org.elasticsearch.indices.store.TransportNodesListShardStoreMetaData.NodeRequest,TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData>
protected TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData nodeOperation(org.elasticsearch.indices.store.TransportNodesListShardStoreMetaData.NodeRequest request) throws ElasticsearchException
nodeOperation
in class TransportNodesOperationAction<org.elasticsearch.indices.store.TransportNodesListShardStoreMetaData.Request,TransportNodesListShardStoreMetaData.NodesStoreFilesMetaData,org.elasticsearch.indices.store.TransportNodesListShardStoreMetaData.NodeRequest,TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData>
ElasticsearchException
protected boolean accumulateExceptions()
accumulateExceptions
in class TransportNodesOperationAction<org.elasticsearch.indices.store.TransportNodesListShardStoreMetaData.Request,TransportNodesListShardStoreMetaData.NodesStoreFilesMetaData,org.elasticsearch.indices.store.TransportNodesListShardStoreMetaData.NodeRequest,TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData>
Copyright © 2009–2015. All rights reserved.