org.elasticsearch.action.admin.indices.gateway.snapshot
Class TransportGatewaySnapshotAction

java.lang.Object
  org.elasticsearch.common.component.AbstractComponent
      org.elasticsearch.action.support.TransportAction<Request,Response>
          org.elasticsearch.action.support.broadcast.TransportBroadcastOperationAction<GatewaySnapshotRequest,GatewaySnapshotResponse,org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotRequest,org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotResponse>
              org.elasticsearch.action.admin.indices.gateway.snapshot.TransportGatewaySnapshotAction

public class TransportGatewaySnapshotAction
extends TransportBroadcastOperationAction<GatewaySnapshotRequest,GatewaySnapshotResponse,org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotRequest,org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotResponse>

Field Summary

Fields inherited from class org.elasticsearch.action.support.broadcast.TransportBroadcastOperationAction

clusterService, threadPool, transportService

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

componentSettings, logger, settings

Constructor Summary

TransportGatewaySnapshotAction(Settings settings, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, IndicesService indicesService)

Method Summary

protected ClusterBlockException	checkGlobalBlock(ClusterState state, GatewaySnapshotRequest request)
protected ClusterBlockException	checkRequestBlock(ClusterState state, GatewaySnapshotRequest request, String[] concreteIndices)
protected String	executor()
protected boolean	ignoreNonActiveExceptions()
protected GatewaySnapshotRequest	newRequest()
protected GatewaySnapshotResponse	newResponse(GatewaySnapshotRequest request, AtomicReferenceArray shardsResponses, ClusterState clusterState)
protected org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotRequest	newShardRequest()
protected org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotRequest	newShardRequest(ShardRouting shard, GatewaySnapshotRequest request)
protected org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotResponse	newShardResponse()
protected org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotResponse	shardOperation(org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotRequest request)
protected GroupShardsIterator	shards(ClusterState clusterState, GatewaySnapshotRequest request, String[] concreteIndices) The snapshot request works against all primary shards.
protected String	transportAction()

Methods inherited from class org.elasticsearch.action.support.broadcast.TransportBroadcastOperationAction

accumulateExceptions, doExecute, ignoreException

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

execute, execute

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

Constructor Detail

TransportGatewaySnapshotAction

@Inject
public TransportGatewaySnapshotAction(Settings settings,
                                             ThreadPool threadPool,
                                             ClusterService clusterService,
                                             TransportService transportService,
                                             IndicesService indicesService)

Method Detail

executor

protected String executor()

Specified by:

executor in class TransportBroadcastOperationAction<GatewaySnapshotRequest,GatewaySnapshotResponse,org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotRequest,org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotResponse>

transportAction

protected String transportAction()

Specified by:

transportAction in class TransportBroadcastOperationAction<GatewaySnapshotRequest,GatewaySnapshotResponse,org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotRequest,org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotResponse>

newRequest

protected GatewaySnapshotRequest newRequest()

Specified by:

newRequest in class TransportBroadcastOperationAction<GatewaySnapshotRequest,GatewaySnapshotResponse,org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotRequest,org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotResponse>

ignoreNonActiveExceptions

protected boolean ignoreNonActiveExceptions()

Overrides:

ignoreNonActiveExceptions in class TransportBroadcastOperationAction<GatewaySnapshotRequest,GatewaySnapshotResponse,org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotRequest,org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotResponse>

newResponse

protected GatewaySnapshotResponse newResponse(GatewaySnapshotRequest request,
                                              AtomicReferenceArray shardsResponses,
                                              ClusterState clusterState)

Specified by:

newResponse in class TransportBroadcastOperationAction<GatewaySnapshotRequest,GatewaySnapshotResponse,org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotRequest,org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotResponse>

newShardRequest

protected org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotRequest newShardRequest()

Specified by:

newShardRequest in class TransportBroadcastOperationAction<GatewaySnapshotRequest,GatewaySnapshotResponse,org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotRequest,org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotResponse>

newShardRequest

protected org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotRequest newShardRequest(ShardRouting shard,
                                                                                                              GatewaySnapshotRequest request)

Specified by:

newShardRequest in class TransportBroadcastOperationAction<GatewaySnapshotRequest,GatewaySnapshotResponse,org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotRequest,org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotResponse>

newShardResponse

protected org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotResponse newShardResponse()

Specified by:

newShardResponse in class TransportBroadcastOperationAction<GatewaySnapshotRequest,GatewaySnapshotResponse,org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotRequest,org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotResponse>

shardOperation

protected org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotResponse shardOperation(org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotRequest request)
                                                                                                       throws ElasticSearchException

Specified by:

shardOperation in class TransportBroadcastOperationAction<GatewaySnapshotRequest,GatewaySnapshotResponse,org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotRequest,org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotResponse>

Throws:

ElasticSearchException

shards

protected GroupShardsIterator shards(ClusterState clusterState,
                                     GatewaySnapshotRequest request,
                                     String[] concreteIndices)

The snapshot request works against all primary shards.

Specified by:

shards in class TransportBroadcastOperationAction<GatewaySnapshotRequest,GatewaySnapshotResponse,org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotRequest,org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotResponse>

checkGlobalBlock

protected ClusterBlockException checkGlobalBlock(ClusterState state,
                                                 GatewaySnapshotRequest request)

Specified by:

checkGlobalBlock in class TransportBroadcastOperationAction<GatewaySnapshotRequest,GatewaySnapshotResponse,org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotRequest,org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotResponse>

checkRequestBlock

protected ClusterBlockException checkRequestBlock(ClusterState state,
                                                  GatewaySnapshotRequest request,
                                                  String[] concreteIndices)

Specified by:

checkRequestBlock in class TransportBroadcastOperationAction<GatewaySnapshotRequest,GatewaySnapshotResponse,org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotRequest,org.elasticsearch.action.admin.indices.gateway.snapshot.ShardGatewaySnapshotResponse>