Class OpenSearchIndexLevelReplicationTestCase.ReplicationAction<Request extends org.opensearch.action.support.replication.ReplicationRequest<Request>, ReplicaRequest extends org.opensearch.action.support.replication.ReplicationRequest<ReplicaRequest>, Response extends org.opensearch.action.support.replication.ReplicationResponse>

java.lang.Object

org.opensearch.index.replication.OpenSearchIndexLevelReplicationTestCase.ReplicationAction<Request, ReplicaRequest, Response>

Enclosing class:

OpenSearchIndexLevelReplicationTestCase

protected abstract class OpenSearchIndexLevelReplicationTestCase.ReplicationAction<Request extends org.opensearch.action.support.replication.ReplicationRequest<Request>, ReplicaRequest extends org.opensearch.action.support.replication.ReplicationRequest<ReplicaRequest>, Response extends org.opensearch.action.support.replication.ReplicationResponse>
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	OpenSearchIndexLevelReplicationTestCase.ReplicationAction.PrimaryResult

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ReplicationAction(Request request, org.opensearch.core.action.ActionListener<Response> listener, OpenSearchIndexLevelReplicationTestCase.ReplicationGroup group, String opType)

Method Summary

Modifier and Type	Method	Description
protected void	adaptResponse(Response response, org.opensearch.index.shard.IndexShard indexShard)
void	execute()
protected org.opensearch.index.shard.IndexShard	getPrimaryShard()
protected abstract void	performOnPrimary(org.opensearch.index.shard.IndexShard primary, Request request, org.opensearch.core.action.ActionListener<OpenSearchIndexLevelReplicationTestCase.ReplicationAction<Request, ReplicaRequest, Response>.PrimaryResult> listener)
protected abstract void	performOnReplica(ReplicaRequest request, org.opensearch.index.shard.IndexShard replica)

Methods inherited from class java.lang.Object

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

Constructor Details

ReplicationAction

protected ReplicationAction(Request request,
 org.opensearch.core.action.ActionListener<Response> listener,
 OpenSearchIndexLevelReplicationTestCase.ReplicationGroup group,
 String opType)

Method Details

execute

public void execute()

adaptResponse

protected void adaptResponse(Response response,
 org.opensearch.index.shard.IndexShard indexShard)

getPrimaryShard

protected org.opensearch.index.shard.IndexShard getPrimaryShard()

performOnPrimary

protected abstract void performOnPrimary(org.opensearch.index.shard.IndexShard primary,
 Request request,
 org.opensearch.core.action.ActionListener<OpenSearchIndexLevelReplicationTestCase.ReplicationAction<Request, ReplicaRequest, Response>.PrimaryResult> listener)

performOnReplica

protected abstract void performOnReplica(ReplicaRequest request,
 org.opensearch.index.shard.IndexShard replica)
                                  throws Exception

Throws:

Exception