Package org.elasticsearch.action.support.replication

Class TransportWriteAction.WritePrimaryResult<ReplicaRequest extends ReplicatedWriteRequest<ReplicaRequest>,Response extends ReplicationResponse & WriteResponse>

java.lang.Object

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

org.elasticsearch.action.support.replication.TransportWriteAction.WritePrimaryResult<ReplicaRequest,Response>

All Implemented Interfaces:

ReplicationOperation.PrimaryResult<ReplicaRequest>

Enclosing class:

TransportWriteAction<Request extends ReplicatedWriteRequest<Request>,ReplicaRequest extends ReplicatedWriteRequest<ReplicaRequest>,Response extends ReplicationResponse & WriteResponse>

public static class TransportWriteAction.WritePrimaryResult<ReplicaRequest extends ReplicatedWriteRequest<ReplicaRequest>,Response extends ReplicationResponse & WriteResponse>
extends TransportReplicationAction.PrimaryResult<ReplicaRequest,Response>

Result of taking the action on the primary. NOTE: public for testing

Field Summary

Fields

Modifier and Type	Field	Description
Translog.Location	location
IndexShard	primary

Fields inherited from class org.elasticsearch.action.support.replication.TransportReplicationAction.PrimaryResult

finalFailure, finalResponseIfSuccessful, replicaRequest

Constructor Summary

Constructors

Constructor	Description
WritePrimaryResult(ReplicaRequest request, Response finalResponse, Translog.Location location, Exception operationFailure, IndexShard primary, org.apache.logging.log4j.Logger logger)

Method Summary

Modifier and Type	Method	Description
void	runPostReplicationActions(ActionListener<Void> listener)	Run actions to be triggered post replication

Methods inherited from class org.elasticsearch.action.support.replication.TransportReplicationAction.PrimaryResult

replicaRequest, setShardInfo

Methods inherited from class java.lang.Object

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

Field Details

location

public final Translog.Location location

primary

public final IndexShard primary

Constructor Details

WritePrimaryResult

public WritePrimaryResult(ReplicaRequest request,
 @Nullable
 Response finalResponse,
 @Nullable
 Translog.Location location,
 @Nullable
 Exception operationFailure,
 IndexShard primary,
 org.apache.logging.log4j.Logger logger)

Method Details

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

Overrides:

runPostReplicationActions in class TransportReplicationAction.PrimaryResult<ReplicaRequest extends ReplicatedWriteRequest<ReplicaRequest>,Response extends ReplicationResponse & WriteResponse>

Parameters:

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