org.elasticsearch.gateway.local.state.shards

Class TransportNodesListGatewayStartedShards

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

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

org.elasticsearch.action.support.nodes.TransportNodesOperationAction<org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.Request,TransportNodesListGatewayStartedShards.NodesLocalGatewayStartedShards,org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.NodeRequest,TransportNodesListGatewayStartedShards.NodeLocalGatewayStartedShards>

org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards

All Implemented Interfaces:

AsyncShardFetch.List<TransportNodesListGatewayStartedShards.NodesLocalGatewayStartedShards,TransportNodesListGatewayStartedShards.NodeLocalGatewayStartedShards>

public class TransportNodesListGatewayStartedShards
extends TransportNodesOperationAction<org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.Request,TransportNodesListGatewayStartedShards.NodesLocalGatewayStartedShards,org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.NodeRequest,TransportNodesListGatewayStartedShards.NodeLocalGatewayStartedShards>
implements AsyncShardFetch.List<TransportNodesListGatewayStartedShards.NodesLocalGatewayStartedShards,TransportNodesListGatewayStartedShards.NodeLocalGatewayStartedShards>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TransportNodesListGatewayStartedShards.NodeLocalGatewayStartedShards
static class	TransportNodesListGatewayStartedShards.NodesLocalGatewayStartedShards

Field Summary

Fields

Modifier and Type	Field and Description
static String	ACTION_NAME

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

clusterName, clusterService, transportService

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

actionName, threadPool

Fields inherited from class org.elasticsearch.common.component.AbstractComponent

componentSettings, logger, settings

Constructor Summary

Constructors

Constructor and Description
TransportNodesListGatewayStartedShards(Settings settings, ClusterName clusterName, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, ActionFilters actionFilters, NodeEnvironment nodeEnvironment)

Method Summary

Modifier and Type	Method and Description
protected boolean	accumulateExceptions()
protected String	executor()
void	list(ShardId shardId, IndexMetaData indexMetaData, String[] nodesIds, ActionListener<TransportNodesListGatewayStartedShards.NodesLocalGatewayStartedShards> listener)
protected org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.NodeRequest	newNodeRequest()
protected org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.NodeRequest	newNodeRequest(String nodeId, org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.Request request)
protected TransportNodesListGatewayStartedShards.NodeLocalGatewayStartedShards	newNodeResponse()
protected org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.Request	newRequest()
protected TransportNodesListGatewayStartedShards.NodesLocalGatewayStartedShards	newResponse(org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.Request request, AtomicReferenceArray responses)
protected TransportNodesListGatewayStartedShards.NodeLocalGatewayStartedShards	nodeOperation(org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.NodeRequest request)
protected String[]	resolveNodes(org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.Request request, ClusterState clusterState)
protected boolean	transportCompress()

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

doExecute, filterNodeIds

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

execute, execute, forceThreadedListener

Methods inherited from class org.elasticsearch.common.component.AbstractComponent

nodeName

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 String ACTION_NAME

See Also:

Constant Field Values

Constructor Detail

TransportNodesListGatewayStartedShards

@Inject
public TransportNodesListGatewayStartedShards(Settings settings,
                                                      ClusterName clusterName,
                                                      ThreadPool threadPool,
                                                      ClusterService clusterService,
                                                      TransportService transportService,
                                                      ActionFilters actionFilters,
                                                      NodeEnvironment nodeEnvironment)

Method Detail

resolveNodes

protected String[] resolveNodes(org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.Request request,
                                ClusterState clusterState)

Overrides:

resolveNodes in class TransportNodesOperationAction<org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.Request,TransportNodesListGatewayStartedShards.NodesLocalGatewayStartedShards,org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.NodeRequest,TransportNodesListGatewayStartedShards.NodeLocalGatewayStartedShards>

list

public void list(ShardId shardId,
                 IndexMetaData indexMetaData,
                 String[] nodesIds,
                 ActionListener<TransportNodesListGatewayStartedShards.NodesLocalGatewayStartedShards> listener)

Specified by:

list in interface AsyncShardFetch.List<TransportNodesListGatewayStartedShards.NodesLocalGatewayStartedShards,TransportNodesListGatewayStartedShards.NodeLocalGatewayStartedShards>

executor

protected String executor()

Specified by:

executor in class TransportNodesOperationAction<org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.Request,TransportNodesListGatewayStartedShards.NodesLocalGatewayStartedShards,org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.NodeRequest,TransportNodesListGatewayStartedShards.NodeLocalGatewayStartedShards>

transportCompress

protected boolean transportCompress()

Overrides:

transportCompress in class TransportNodesOperationAction<org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.Request,TransportNodesListGatewayStartedShards.NodesLocalGatewayStartedShards,org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.NodeRequest,TransportNodesListGatewayStartedShards.NodeLocalGatewayStartedShards>

newRequest

protected org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.Request newRequest()

Specified by:

newRequest in class TransportNodesOperationAction<org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.Request,TransportNodesListGatewayStartedShards.NodesLocalGatewayStartedShards,org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.NodeRequest,TransportNodesListGatewayStartedShards.NodeLocalGatewayStartedShards>

newNodeRequest

protected org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.NodeRequest newNodeRequest()

Specified by:

newNodeRequest in class TransportNodesOperationAction<org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.Request,TransportNodesListGatewayStartedShards.NodesLocalGatewayStartedShards,org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.NodeRequest,TransportNodesListGatewayStartedShards.NodeLocalGatewayStartedShards>

newNodeRequest

protected org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.NodeRequest newNodeRequest(String nodeId,
                                                                                                                         org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.Request request)

Specified by:

newNodeRequest in class TransportNodesOperationAction<org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.Request,TransportNodesListGatewayStartedShards.NodesLocalGatewayStartedShards,org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.NodeRequest,TransportNodesListGatewayStartedShards.NodeLocalGatewayStartedShards>

newNodeResponse

protected TransportNodesListGatewayStartedShards.NodeLocalGatewayStartedShards newNodeResponse()

Specified by:

newNodeResponse in class TransportNodesOperationAction<org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.Request,TransportNodesListGatewayStartedShards.NodesLocalGatewayStartedShards,org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.NodeRequest,TransportNodesListGatewayStartedShards.NodeLocalGatewayStartedShards>

newResponse

protected TransportNodesListGatewayStartedShards.NodesLocalGatewayStartedShards newResponse(org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.Request request,
                                                                                            AtomicReferenceArray responses)

Specified by:

newResponse in class TransportNodesOperationAction<org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.Request,TransportNodesListGatewayStartedShards.NodesLocalGatewayStartedShards,org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.NodeRequest,TransportNodesListGatewayStartedShards.NodeLocalGatewayStartedShards>

nodeOperation

protected TransportNodesListGatewayStartedShards.NodeLocalGatewayStartedShards nodeOperation(org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.NodeRequest request)
                                                                                      throws ElasticsearchException

Specified by:

nodeOperation in class TransportNodesOperationAction<org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.Request,TransportNodesListGatewayStartedShards.NodesLocalGatewayStartedShards,org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.NodeRequest,TransportNodesListGatewayStartedShards.NodeLocalGatewayStartedShards>

Throws:

ElasticsearchException

accumulateExceptions

protected boolean accumulateExceptions()

Specified by:

accumulateExceptions in class TransportNodesOperationAction<org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.Request,TransportNodesListGatewayStartedShards.NodesLocalGatewayStartedShards,org.elasticsearch.gateway.local.state.shards.TransportNodesListGatewayStartedShards.NodeRequest,TransportNodesListGatewayStartedShards.NodeLocalGatewayStartedShards>