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