Module org.elasticsearch.server

Package org.elasticsearch.action.support.replication

Class ReplicationSplitHelper<Request extends ReplicationRequest<Request>,ReplicaRequest extends ReplicationRequest<ReplicaRequest>,Response extends ReplicationResponse>

java.lang.Object

org.elasticsearch.action.support.replication.ReplicationSplitHelper<Request,ReplicaRequest,Response>

public class ReplicationSplitHelper<Request extends ReplicationRequest<Request>,ReplicaRequest extends ReplicationRequest<ReplicaRequest>,Response extends ReplicationResponse>
extends Object

This class implements the coordination logic during a split. If documents are only routed to the source then it will be a normal primary action. If documents are only routed to the target it will be delegated to the target. If documents are routed to both then the request will be split into two and executed locally and delegated to the target.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ReplicationSplitHelper.PrimaryRequestExecutor<Request extends ReplicationRequest<Request>,ReplicaRequest extends ReplicationRequest<ReplicaRequest>,Response extends ReplicationResponse>
class	ReplicationSplitHelper.SplitCoordinator

Field Summary

Fields

Modifier and Type	Field	Description
static TransportVersion	STALE_REQUEST_EXCEPTION_VERSION

Constructor Summary

Constructors

Constructor	Description
ReplicationSplitHelper(org.apache.logging.log4j.Logger logger, ClusterService clusterService, TimeValue initialRetryBackoffBound, TimeValue retryTimeout, TriConsumer<DiscoveryNode,TransportReplicationAction.ConcreteShardRequest<Request>,ActionListener<Response>> primaryRequestSender)

Method Summary

Modifier and Type	Method	Description
static <Request extends ReplicationRequest<Request>> boolean	needsSplitCoordination(org.apache.logging.log4j.Logger logger, Request primaryRequest, IndexMetadata indexMetadata)
ReplicationSplitHelper<Request,ReplicaRequest,Response>.SplitCoordinator	newSplitRequest(TransportReplicationAction<Request,ReplicaRequest,Response> action, ReplicationTask task, ProjectMetadata project, TransportReplicationAction<Request,ReplicaRequest,Response>.org.elasticsearch.action.support.replication.TransportReplicationAction.PrimaryShardReference primaryShardReference, Request primaryRequest, ReplicationSplitHelper.PrimaryRequestExecutor<Request,ReplicaRequest,Response> executePrimaryRequest, ActionListener<Response> onCompletionListener)

Methods inherited from class java.lang.Object

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

Field Details

STALE_REQUEST_EXCEPTION_VERSION

public static TransportVersion STALE_REQUEST_EXCEPTION_VERSION

Constructor Details

ReplicationSplitHelper

public ReplicationSplitHelper(org.apache.logging.log4j.Logger logger,
 ClusterService clusterService,
 TimeValue initialRetryBackoffBound,
 TimeValue retryTimeout,
 TriConsumer<DiscoveryNode,TransportReplicationAction.ConcreteShardRequest<Request>,ActionListener<Response>> primaryRequestSender)

Method Details

needsSplitCoordination

public static <Request extends ReplicationRequest<Request>>
boolean needsSplitCoordination(org.apache.logging.log4j.Logger logger,
 Request primaryRequest,
 IndexMetadata indexMetadata)
                        throws Exception

Throws:

Exception

newSplitRequest

public ReplicationSplitHelper<Request,ReplicaRequest,Response>.SplitCoordinator newSplitRequest(TransportReplicationAction<Request,ReplicaRequest,Response> action,
 ReplicationTask task,
 ProjectMetadata project,
 TransportReplicationAction<Request,ReplicaRequest,Response>.org.elasticsearch.action.support.replication.TransportReplicationAction.PrimaryShardReference primaryShardReference,
 Request primaryRequest,
 ReplicationSplitHelper.PrimaryRequestExecutor<Request,ReplicaRequest,Response> executePrimaryRequest,
 ActionListener<Response> onCompletionListener)