Package org.elasticsearch.action.support.replication

Class ReplicationOperation<Request extends ReplicationRequest<Request>,ReplicaRequest extends ReplicationRequest<ReplicaRequest>,PrimaryResultT extends ReplicationOperation.PrimaryResult<ReplicaRequest>>

org.elasticsearch.action.support.replication.ReplicationOperation<Request,ReplicaRequest,PrimaryResultT>

public class ReplicationOperation<Request extends ReplicationRequest<Request>,ReplicaRequest extends ReplicationRequest<ReplicaRequest>,PrimaryResultT extends ReplicationOperation.PrimaryResult<ReplicaRequest>>
extends 

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ReplicationOperation.Primary<RequestT extends ReplicationRequest<RequestT>,ReplicaRequestT extends ReplicationRequest<ReplicaRequestT>,PrimaryResultT extends ReplicationOperation.PrimaryResult<ReplicaRequestT>>	An encapsulation of an operation that is to be performed on the primary shard
static interface	ReplicationOperation.PrimaryResult<RequestT extends ReplicationRequest<RequestT>>
static interface	ReplicationOperation.ReplicaResponse	An interface to encapsulate the metadata needed from replica shards when they respond to operations performed on them.
static interface	ReplicationOperation.Replicas<RequestT extends ReplicationRequest<RequestT>>	An encapsulation of an operation that will be executed on the replica shards, if present.
static class	ReplicationOperation.RetryOnPrimaryException

Constructor Summary

Constructors

Constructor

Description

ReplicationOperation(Request request, ReplicationOperation.Primary<Request,ReplicaRequest,PrimaryResultT> primary, ActionListener<PrimaryResultT> listener, ReplicationOperation.Replicas<ReplicaRequest> replicas, org.apache.logging.log4j.Logger logger, ThreadPool threadPool, opType, long primaryTerm, org.elasticsearch.core.TimeValue initialRetryBackoffBound, org.elasticsearch.core.TimeValue retryTimeout)

Method Summary

Modifier and Type	Method	Description
protected	checkActiveShardCount()	Checks whether we can perform a write based on the required active shard count setting.
void	execute()

Methods inherited from class java.lang.

, , , , , , , , , ,

Constructor Details

ReplicationOperation

public ReplicationOperation(Request request,
 ReplicationOperation.Primary<Request,ReplicaRequest,PrimaryResultT> primary,
 ActionListener<PrimaryResultT> listener,
 ReplicationOperation.Replicas<ReplicaRequest> replicas,
 org.apache.logging.log4j.Logger logger,
 ThreadPool threadPool,
  opType,
 long primaryTerm,
 org.elasticsearch.core.TimeValue initialRetryBackoffBound,
 org.elasticsearch.core.TimeValue retryTimeout)

Method Details

execute

public void execute()
             throws 

Throws:

checkActiveShardCount

protected  checkActiveShardCount()

Checks whether we can perform a write based on the required active shard count setting. Returns **null* if OK to proceed, or a string describing the reason to stop