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>

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

Field Summary

Fields

Modifier and Type	Field and Description
Translog.Location	location

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

finalFailure, finalResponseIfSuccessful

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	onFailure(java.lang.Exception exception) Called on failure if a post action failed.
void	onSuccess(boolean forcedRefresh) Called on successful processing of all post write actions
void	respond(ActionListener<Response> listener)
protected void	respondIfPossible(java.lang.Exception ex) Respond if the refresh has occurred and the listener is ready.

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 Detail

location

public final Translog.Location location

Constructor Detail

WritePrimaryResult

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

Method Detail

respond

public void respond(ActionListener<Response> listener)

Overrides:

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

respondIfPossible

protected void respondIfPossible(java.lang.Exception ex)

Respond if the refresh has occurred and the listener is ready. Always called while synchronized on this.

onFailure

public void onFailure(java.lang.Exception exception)

Called on failure if a post action failed.

onSuccess

public void onSuccess(boolean forcedRefresh)

Called on successful processing of all post write actions

Parameters:

forcedRefresh - true iff this write has caused a refresh