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>

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

Field Summary

Fields

Modifier and Type	Field	Description
java.lang.Exception	finalFailure
Response	finalResponseIfSuccessful

Constructor Summary

Constructors

Constructor	Description
PrimaryResult(ReplicaRequest replicaRequest, Response replicationResponse)
PrimaryResult(ReplicaRequest replicaRequest, Response finalResponseIfSuccessful, java.lang.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	respond(ActionListener<Response> listener)
void	setShardInfo(ReplicationResponse.ShardInfo shardInfo)

Methods inherited from class java.lang.Object

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

Field Detail

finalResponseIfSuccessful

public final Response extends ReplicationResponse finalResponseIfSuccessful

finalFailure

public final java.lang.Exception finalFailure

Constructor Detail

PrimaryResult

public PrimaryResult(ReplicaRequest replicaRequest,
                     Response finalResponseIfSuccessful,
                     java.lang.Exception finalFailure)

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

PrimaryResult

public PrimaryResult(ReplicaRequest replicaRequest,
                     Response replicationResponse)

Method Detail

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

respond

public void respond(ActionListener<Response> listener)