org.elasticsearch.action.support.replication

Class TransportShardReplicationOperationAction<Request extends ShardReplicationOperationRequest,ReplicaRequest extends ShardReplicationOperationRequest,Response extends ActionResponse>

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

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

org.elasticsearch.action.support.replication.TransportShardReplicationOperationAction<Request,ReplicaRequest,Response>

Direct Known Subclasses:

TransportDeleteAction, TransportIndexAction, TransportShardBulkAction, TransportShardDeleteAction, TransportShardDeleteByQueryAction

public abstract class TransportShardReplicationOperationAction<Request extends ShardReplicationOperationRequest,ReplicaRequest extends ShardReplicationOperationRequest,Response extends ActionResponse>
extends TransportAction<Request,Response>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	TransportShardReplicationOperationAction.InternalRequest Internal request class that gets built on each node.
protected class	TransportShardReplicationOperationAction.PrimaryOperationRequest
protected class	TransportShardReplicationOperationAction.ReplicaOperationRequest

Field Summary

Fields

Modifier and Type	Field and Description
protected ClusterService	clusterService
protected ReplicationType	defaultReplicationType
protected WriteConsistencyLevel	defaultWriteConsistencyLevel
protected IndicesService	indicesService
protected ShardStateAction	shardStateAction
protected TransportRequestOptions	transportOptions
protected TransportService	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

Modifier	Constructor and Description
protected	TransportShardReplicationOperationAction(Settings settings, String actionName, TransportService transportService, ClusterService clusterService, IndicesService indicesService, ThreadPool threadPool, ShardStateAction shardStateAction, ActionFilters actionFilters)

Method Summary

Modifier and Type	Method and Description
protected ClusterBlockException	checkGlobalBlock(ClusterState state)
protected ClusterBlockException	checkRequestBlock(ClusterState state, TransportShardReplicationOperationAction.InternalRequest request)
protected abstract boolean	checkWriteConsistency()
protected void	doExecute(Request request, ActionListener<Response> listener)
protected abstract String	executor()
protected Releasable	getIndexShardOperationsCounter(ShardId shardId)
protected boolean	ignoreReplicaException(Throwable e) Should an exception be ignored when the operation is performed on the replica.
protected boolean	isConflictException(Throwable e)
protected abstract ReplicaRequest	newReplicaRequestInstance()
protected abstract Request	newRequestInstance()
protected abstract Response	newResponseInstance()
protected abstract boolean	resolveIndex()
protected boolean	resolveRequest(ClusterState state, TransportShardReplicationOperationAction.InternalRequest request, ActionListener<Response> listener) Resolves the request, by default doing nothing.
protected boolean	retryPrimaryException(Throwable e)
protected abstract Tuple<Response,ReplicaRequest>	shardOperationOnPrimary(ClusterState clusterState, TransportShardReplicationOperationAction.PrimaryOperationRequest shardRequest)
protected abstract void	shardOperationOnReplica(TransportShardReplicationOperationAction.ReplicaOperationRequest shardRequest)
protected abstract ShardIterator	shards(ClusterState clusterState, TransportShardReplicationOperationAction.InternalRequest request)
protected TransportRequestOptions	transportOptions()

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

transportService

protected final TransportService transportService

clusterService

protected final ClusterService clusterService

indicesService

protected final IndicesService indicesService

shardStateAction

protected final ShardStateAction shardStateAction

defaultReplicationType

protected final ReplicationType defaultReplicationType

defaultWriteConsistencyLevel

protected final WriteConsistencyLevel defaultWriteConsistencyLevel

transportOptions

protected final TransportRequestOptions transportOptions

Constructor Detail

TransportShardReplicationOperationAction

protected TransportShardReplicationOperationAction(Settings settings,
                                                   String actionName,
                                                   TransportService transportService,
                                                   ClusterService clusterService,
                                                   IndicesService indicesService,
                                                   ThreadPool threadPool,
                                                   ShardStateAction shardStateAction,
                                                   ActionFilters actionFilters)

Method Detail

doExecute

protected void doExecute(Request request,
                         ActionListener<Response> listener)

Specified by:

doExecute in class TransportAction<Request extends ShardReplicationOperationRequest,Response extends ActionResponse>

newRequestInstance

protected abstract Request newRequestInstance()

newReplicaRequestInstance

protected abstract ReplicaRequest newReplicaRequestInstance()

newResponseInstance

protected abstract Response newResponseInstance()

executor

protected abstract String executor()

shardOperationOnReplica

protected abstract void shardOperationOnReplica(TransportShardReplicationOperationAction.ReplicaOperationRequest shardRequest)

shardOperationOnPrimary

protected abstract Tuple<Response,ReplicaRequest> shardOperationOnPrimary(ClusterState clusterState,
                                                                          TransportShardReplicationOperationAction.PrimaryOperationRequest shardRequest)
                                                                   throws Throwable

Returns:

A tuple containing not null values, as first value the result of the primary operation and as second value the request to be executed on the replica shards.

Throws:

Throwable

shards

protected abstract ShardIterator shards(ClusterState clusterState,
                                        TransportShardReplicationOperationAction.InternalRequest request)
                                 throws ElasticsearchException

Throws:

ElasticsearchException

checkWriteConsistency

protected abstract boolean checkWriteConsistency()

checkGlobalBlock

protected ClusterBlockException checkGlobalBlock(ClusterState state)

checkRequestBlock

protected ClusterBlockException checkRequestBlock(ClusterState state,
                                                  TransportShardReplicationOperationAction.InternalRequest request)

resolveIndex

protected abstract boolean resolveIndex()

resolveRequest

protected boolean resolveRequest(ClusterState state,
                                 TransportShardReplicationOperationAction.InternalRequest request,
                                 ActionListener<Response> listener)

Resolves the request, by default doing nothing. If the resolve means a different execution, then return false here to indicate not to continue and execute this request.

transportOptions

protected TransportRequestOptions transportOptions()

retryPrimaryException

protected boolean retryPrimaryException(Throwable e)

ignoreReplicaException

protected boolean ignoreReplicaException(Throwable e)

Should an exception be ignored when the operation is performed on the replica.

isConflictException

protected boolean isConflictException(Throwable e)

getIndexShardOperationsCounter

protected Releasable getIndexShardOperationsCounter(ShardId shardId)