Package org.elasticsearch.action.support.replication

Class TransportReplicationAction.PrimaryResult<ReplicaRequest extends ReplicationRequest<ReplicaRequest>,Response extends ReplicationResponse>

java.lang.Object

org.elasticsearch.action.support.replication.TransportReplicationAction.PrimaryResult<ReplicaRequest,Response>

All Implemented Interfaces:

ReplicationOperation.PrimaryResult<ReplicaRequest>

Direct Known Subclasses:

TransportWriteAction.WritePrimaryResult

Enclosing class:

TransportReplicationAction<Request extends ReplicationRequest<Request>,ReplicaRequest extends ReplicationRequest<ReplicaRequest>,Response extends ReplicationResponse>

public static class TransportReplicationAction.PrimaryResult<ReplicaRequest extends ReplicationRequest<ReplicaRequest>,Response extends ReplicationResponse>
extends Object
implements ReplicationOperation.PrimaryResult<ReplicaRequest>

Field Summary

Fields

Modifier and Type	Field	Description
final Exception	finalFailure
final Response	finalResponseIfSuccessful
protected final ReplicaRequest	replicaRequest

Constructor Summary

Constructors

Constructor	Description
PrimaryResult(ReplicaRequest replicaRequest, Response replicationResponse)
PrimaryResult(ReplicaRequest replicaRequest, Response finalResponseIfSuccessful, Exception finalFailure)	Result of executing a primary operation expects finalResponseIfSuccessful or finalFailure to be not-null

Method Summary

Modifier and Type	Method	Description
ReplicaRequest	replicaRequest()
void	runPostReplicationActions(ActionListener<Void> listener)	Run actions to be triggered post replication
void	setShardInfo(ReplicationResponse.ShardInfo shardInfo)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

replicaRequest

protected final ReplicaRequest extends ReplicationRequest<ReplicaRequest> replicaRequest

finalResponseIfSuccessful

public final Response extends ReplicationResponse finalResponseIfSuccessful

finalFailure

public final Exception finalFailure

Constructor Details

PrimaryResult

public PrimaryResult(ReplicaRequest replicaRequest,
 Response finalResponseIfSuccessful,
 Exception finalFailure)

Result of executing a primary operation expects finalResponseIfSuccessful or finalFailure to be not-null

PrimaryResult

public PrimaryResult(ReplicaRequest replicaRequest,
 Response replicationResponse)

Method Details

replicaRequest

public ReplicaRequest replicaRequest()

Specified by:

replicaRequest in interface ReplicationOperation.PrimaryResult<ReplicaRequest extends ReplicationRequest<ReplicaRequest>>

Returns:

null if no operation needs to be sent to a replica (for example when the operation failed on the primary due to a parsing exception)

setShardInfo

public void setShardInfo(ReplicationResponse.ShardInfo shardInfo)

Specified by:

setShardInfo in interface ReplicationOperation.PrimaryResult<ReplicaRequest extends ReplicationRequest<ReplicaRequest>>

runPostReplicationActions

public void runPostReplicationActions(ActionListener<Void> listener)

Description copied from interface: ReplicationOperation.PrimaryResult

Run actions to be triggered post replication

Specified by:

runPostReplicationActions in interface ReplicationOperation.PrimaryResult<ReplicaRequest extends ReplicationRequest<ReplicaRequest>>

Parameters:

listener - calllback that is invoked after post replication actions have completed