Class OpenSearchIndexLevelReplicationTestCase

java.lang.Object

org.junit.Assert

org.apache.lucene.tests.util.LuceneTestCase

org.opensearch.test.OpenSearchTestCase

org.opensearch.index.shard.IndexShardTestCase

org.opensearch.index.replication.OpenSearchIndexLevelReplicationTestCase

public abstract class OpenSearchIndexLevelReplicationTestCase
extends IndexShardTestCase

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected 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>
protected class	OpenSearchIndexLevelReplicationTestCase.ReplicationGroup

Nested classes/interfaces inherited from class org.opensearch.test.OpenSearchTestCase

OpenSearchTestCase.AnnotatedFeatureFlagRule, OpenSearchTestCase.GeohashGenerator, OpenSearchTestCase.LockFeatureFlag, OpenSearchTestCase.TestAnalysis

Nested classes/interfaces inherited from class org.apache.lucene.tests.util.LuceneTestCase

org.apache.lucene.tests.util.LuceneTestCase.AwaitsFix, org.apache.lucene.tests.util.LuceneTestCase.Concurrency, org.apache.lucene.tests.util.LuceneTestCase.Monster, org.apache.lucene.tests.util.LuceneTestCase.Nightly, org.apache.lucene.tests.util.LuceneTestCase.SuppressCodecs, org.apache.lucene.tests.util.LuceneTestCase.SuppressFileSystems, org.apache.lucene.tests.util.LuceneTestCase.SuppressFsync, org.apache.lucene.tests.util.LuceneTestCase.SuppressReproduceLine, org.apache.lucene.tests.util.LuceneTestCase.SuppressSysoutChecks, org.apache.lucene.tests.util.LuceneTestCase.SuppressTempFileChecks, org.apache.lucene.tests.util.LuceneTestCase.ThrowingConsumer<T>, org.apache.lucene.tests.util.LuceneTestCase.ThrowingRunnable, org.apache.lucene.tests.util.LuceneTestCase.Weekly

Field Summary

Fields

Modifier and Type	Field	Description
protected final org.opensearch.core.index.Index	index
protected final String	indexMapping

Fields inherited from class org.opensearch.index.shard.IndexShardTestCase

clusterService, currentClusterStateVersion, EMPTY_EVENT_LISTENER, primaryTerm, recoveryListener, threadPool

Fields inherited from class org.opensearch.test.OpenSearchTestCase

checkIndexFailures, DEFAULT_NAMED_WRITABLE_REGISTRY, DEFAULT_TEST_WORKER_ID, failureAndSuccessEvents, flagLockRule, JAVA_TIMEZONE_IDS, JAVA_ZONE_IDS, JODA_TIMEZONE_IDS, logger, TEST_WORKER_SYS_PROPERTY, TEST_WORKER_VM_ID

Fields inherited from class org.apache.lucene.tests.util.LuceneTestCase

assertsAreEnabled, classRules, DEFAULT_LINE_DOCS_FILE, INFOSTREAM, JENKINS_LARGE_LINE_DOCS_FILE, LEAVE_TEMPORARY, MAYBE_CACHE_POLICY, RANDOM_MULTIPLIER, ruleChain, suiteFailureMarker, SYSPROP_AWAITSFIX, SYSPROP_FAILFAST, SYSPROP_MAXFAILURES, SYSPROP_MONSTER, SYSPROP_NIGHTLY, SYSPROP_WEEKLY, TEST_ASSERTS_ENABLED, TEST_AWAITSFIX, TEST_CODEC, TEST_DIRECTORY, TEST_DOCVALUESFORMAT, TEST_LINE_DOCS_FILE, TEST_MONSTER, TEST_NIGHTLY, TEST_POSTINGSFORMAT, TEST_THROTTLING, TEST_WEEKLY, VERBOSE

Constructor Summary

Constructors

Constructor	Description
OpenSearchIndexLevelReplicationTestCase()

Method Summary

Modifier and Type	Method	Description
protected org.opensearch.cluster.metadata.IndexMetadata	buildIndexMetadata(int replicas)
protected org.opensearch.cluster.metadata.IndexMetadata	buildIndexMetadata(int replicas, String mappings)
protected org.opensearch.cluster.metadata.IndexMetadata	buildIndexMetadata(int replicas, org.opensearch.common.settings.Settings indexSettings, String mappings)
protected OpenSearchIndexLevelReplicationTestCase.ReplicationGroup	createGroup(int replicas)
protected OpenSearchIndexLevelReplicationTestCase.ReplicationGroup	createGroup(int replicas, org.opensearch.common.settings.Settings settings)
protected OpenSearchIndexLevelReplicationTestCase.ReplicationGroup	createGroup(int replicas, org.opensearch.common.settings.Settings settings, String mappings, org.opensearch.index.engine.EngineFactory engineFactory)
protected OpenSearchIndexLevelReplicationTestCase.ReplicationGroup	createGroup(int replicas, org.opensearch.common.settings.Settings settings, String mappings, org.opensearch.index.engine.EngineFactory engineFactory, Path remotePath)
protected OpenSearchIndexLevelReplicationTestCase.ReplicationGroup	createGroup(int replicas, org.opensearch.common.settings.Settings settings, org.opensearch.index.engine.EngineFactory engineFactory)
protected org.opensearch.cluster.node.DiscoveryNode	getDiscoveryNode(String id)
org.opensearch.action.bulk.BulkShardRequest	indexOnPrimary(org.opensearch.action.index.IndexRequest request, org.opensearch.index.shard.IndexShard primary)	indexes the given requests on the supplied primary, modifying it for replicas
void	indexOnReplica(org.opensearch.action.bulk.BulkShardRequest request, OpenSearchIndexLevelReplicationTestCase.ReplicationGroup group, org.opensearch.index.shard.IndexShard replica)	indexes the given requests on the supplied replica shard

Methods inherited from class org.opensearch.index.shard.IndexShardTestCase

acquirePrimaryOperationPermitBlockingly, allowShardFailures, assertConsistentHistoryBetweenTranslogAndLucene, assertDocCount, assertDocs, closeShard, closeShards, closeShards, createRemoteSegmentStoreDirectory, createRemoteStore, createRepositoriesService, createStore, createStore, createTestWarmer, deleteDoc, failOnShardFailures, flushShard, flushShard, getBlobContainer, getDocIdAndSeqNos, getEngine, getMergedSegmentTargetListener, getReplicationFunc, getReplicationTracker, getSegmentReplicationSource, getShardDocUIDs, getTargetListener, getTranslog, indexDoc, indexDoc, indexDoc, newShard, newShard, newShard, newShard, newShard, newShard, newShard, newShard, newShard, newShard, newShard, newShard, newShard, newShard, newShard, newStartedShard, newStartedShard, newStartedShard, newStartedShard, newStartedShard, newStartedShard, prepareForReplication, prepareForReplication, promoteReplica, recoverFromStore, recoverReplica, recoverReplica, recoverReplica, recoverReplica, recoverShardFromSnapshot, recoverShardFromStore, recoverUnstartedReplica, recoveryEmptyReplica, reinitShard, reinitShard, reinitShard, reinitShard, reinitShard, replicateMergedSegments, replicateSegments, setUp, setUpThreadPool, snapshotShard, startReplicaAfterRecovery, tearDown, tearDownThreadPool, threadPoolSettings, updateMappings, updateRoutingEntry

Methods inherited from class org.opensearch.test.OpenSearchTestCase

after, afterIfFailed, afterIfSuccessful, allowedWarnings, assertArrayEquals, assertBusy, assertBusy, assertBusyWithFixedSleepTime, assertEquals, assertNoDeprecationWarnings, assertSettingDeprecationsAndWarnings, assertSettingDeprecationsAndWarnings, assertWarnings, assertWarnings, before, between, buildEnvSettings, buildNewFakeTransportAddress, checkStaticState, clearAdditionalRoles, copyInstance, copyNamedWriteable, copyNamedWriteable, copyWriteable, copyWriteable, createDefaultIndexAnalyzers, createParser, createParser, createParser, createParser, createParser, createParser, createTestAnalysis, createTestAnalysis, createTestAnalysis, enableJodaDeprecationWarningsCheck, enableWarningsCheck, ensureAllSearchContextsReleased, ensureCheckIndexPassed, ensureSupportedLocale, frequently, generateRandomStringArray, generateRandomStringArray, getBasePort, getBasePort, getDataPath, getPortRange, getShardLevelBlobPath, getSuiteFailureMarker, getTestTransportPlugin, getTestTransportType, inFipsJvm, iterations, maybeSet, mockScript, newNodeEnvironment, newNodeEnvironment, persistedStateRegistry, randomAlphaOfLength, randomAlphaOfLengthBetween, randomArray, randomArray, randomBigInteger, randomBoolean, randomByte, randomByteArrayOfLength, randomDateFormatterPattern, randomDateTimeZone, randomDouble, randomDoubleBetween, randomFloat, randomFrom, randomFrom, randomFrom, randomFrom, randomFrom, randomGeohash, randomInt, randomInt, randomIntBetween, randomIp, randomList, randomList, randomLong, randomLongBetween, randomNonNegativeInt, randomNonNegativeLong, randomPositiveTimeValue, randomRealisticUnicodeOfCodepointLength, randomRealisticUnicodeOfCodepointLengthBetween, randomRealisticUnicodeOfLength, randomRealisticUnicodeOfLengthBetween, randomShort, randomSubsetOf, randomSubsetOf, randomSubsetOf, randomTimeValue, randomTimeValue, randomTimeValue, randomTimeZone, randomUnicodeOfCodepointLength, randomUnicodeOfCodepointLengthBetween, randomUnicodeOfLength, randomUnicodeOfLengthBetween, randomUnique, randomUnsignedLong, randomValueOtherThan, randomValueOtherThanMany, randomZone, remoteIndexSettings, removeHeaderWarningAppender, replaceUnicodeControlCharacters, replaceUnicodeControlCharacters, resetCheckIndexStatus, resetPortCounter, restoreContentType, restoreFileSystem, scaledRandomIntBetween, setContentType, setFileSystem, setHeaderWarningAppender, settings, shuffleMap, shuffleXContent, shuffleXContent, spinForAtLeastNMilliseconds, spinForAtLeastOneMillisecond, terminate, terminate, tmpPaths, toShuffledXContent, toShuffledXContent, waitUntil, waitUntil, warmIndexSettings, writableRegistry, xContentRegistry

Methods inherited from class org.apache.lucene.tests.util.LuceneTestCase

addVirusChecker, assertDeletedDocsEquals, assertDocsAndPositionsEnumEquals, assertDocsEnumEquals, assertDocsSkippingEquals, assertDocValuesEquals, assertDocValuesEquals, assertDoubleUlpEquals, assertFieldInfosEquals, assertFloatUlpEquals, assertNormsEquals, assertPointsEquals, assertPositionsSkippingEquals, assertReaderEquals, assertReaderStatisticsEquals, assertStoredFieldEquals, assertStoredFieldsEquals, assertTermsEnumEquals, assertTermsEquals, assertTermsEquals, assertTermsStatisticsEquals, assertTermStatsEquals, assertTermVectorsEquals, assertThat, assertThat, asSet, assumeFalse, assumeNoException, assumeTrue, atLeast, atLeast, callStackContains, callStackContains, callStackContainsAnyOf, closeAfterSuite, closeAfterTest, collate, createTempDir, createTempDir, createTempFile, createTempFile, dumpArray, dumpIterator, ensureSaneIWCOnNightly, expectThrows, expectThrows, expectThrows, expectThrowsAnyOf, expectThrowsAnyOf, getDataInputStream, getJvmForkArguments, getOnlyLeafReader, getTestClass, getTestName, isTestThread, localeForLanguageTag, maybeChangeLiveIndexWriterConfig, maybeWrapReader, newAlcoholicMergePolicy, newAlcoholicMergePolicy, newBytesRef, newBytesRef, newBytesRef, newBytesRef, newBytesRef, newBytesRef, newDirectory, newDirectory, newDirectory, newDirectory, newDirectory, newField, newField, newFSDirectory, newFSDirectory, newIndexWriterConfig, newIndexWriterConfig, newIndexWriterConfig, newIOContext, newIOContext, newLogMergePolicy, newLogMergePolicy, newLogMergePolicy, newLogMergePolicy, newLogMergePolicy, newMaybeVirusCheckingDirectory, newMaybeVirusCheckingFSDirectory, newMergePolicy, newMergePolicy, newMergePolicy, newMockDirectory, newMockDirectory, newMockDirectory, newMockFSDirectory, newMockFSDirectory, newSearcher, newSearcher, newSearcher, newSearcher, newSearcher, newSnapshotIndexWriterConfig, newStringField, newStringField, newStringField, newStringField, newTextField, newTextField, newTieredMergePolicy, newTieredMergePolicy, overrideDefaultQueryCache, overrideTestDefaultQueryCache, random, randomLocale, randomTimeZone, randomVectorFormat, rarely, rarely, replaceMaxFailureRule, resetDefaultQueryCache, restoreCPUCoreCount, restoreIndexWriterMaxDocs, runWithRestrictedPermissions, setIndexWriterMaxDocs, setupCPUCoreCount, setUpExecutorService, shutdownExecutorService, slowFileExists, usually, usually, wrapReader

Methods inherited from class org.junit.Assert

assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertFalse, assertFalse, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotNull, assertNotNull, assertNotSame, assertNotSame, assertNull, assertNull, assertSame, assertSame, assertThrows, assertThrows, assertTrue, assertTrue, fail, fail

Methods inherited from class java.lang.Object

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

Field Details

index

protected final org.opensearch.core.index.Index index

indexMapping

protected final String indexMapping

See Also:

• Constant Field Values

Constructor Details

OpenSearchIndexLevelReplicationTestCase

public OpenSearchIndexLevelReplicationTestCase()

Method Details

createGroup

protected OpenSearchIndexLevelReplicationTestCase.ReplicationGroup createGroup(int replicas)
                                                                        throws IOException

Throws:

IOException

createGroup

protected OpenSearchIndexLevelReplicationTestCase.ReplicationGroup createGroup(int replicas,
 org.opensearch.common.settings.Settings settings)
                                                                        throws IOException

Throws:

IOException

createGroup

protected OpenSearchIndexLevelReplicationTestCase.ReplicationGroup createGroup(int replicas,
 org.opensearch.common.settings.Settings settings,
 org.opensearch.index.engine.EngineFactory engineFactory)
                                                                        throws IOException

Throws:

IOException

createGroup

protected OpenSearchIndexLevelReplicationTestCase.ReplicationGroup createGroup(int replicas,
 org.opensearch.common.settings.Settings settings,
 String mappings,
 org.opensearch.index.engine.EngineFactory engineFactory)
                                                                        throws IOException

Throws:

IOException

createGroup

protected OpenSearchIndexLevelReplicationTestCase.ReplicationGroup createGroup(int replicas,
 org.opensearch.common.settings.Settings settings,
 String mappings,
 org.opensearch.index.engine.EngineFactory engineFactory,
 Path remotePath)
                                                                        throws IOException

Throws:

IOException

buildIndexMetadata

protected org.opensearch.cluster.metadata.IndexMetadata buildIndexMetadata(int replicas)
                                                                    throws IOException

Throws:

IOException

buildIndexMetadata

protected org.opensearch.cluster.metadata.IndexMetadata buildIndexMetadata(int replicas,
 String mappings)
                                                                    throws IOException

Throws:

IOException

buildIndexMetadata

protected org.opensearch.cluster.metadata.IndexMetadata buildIndexMetadata(int replicas,
 org.opensearch.common.settings.Settings indexSettings,
 String mappings)
                                                                    throws IOException

Throws:

IOException

getDiscoveryNode

protected org.opensearch.cluster.node.DiscoveryNode getDiscoveryNode(String id)

indexOnPrimary

public org.opensearch.action.bulk.BulkShardRequest indexOnPrimary(org.opensearch.action.index.IndexRequest request,
 org.opensearch.index.shard.IndexShard primary)
                                                           throws Exception

indexes the given requests on the supplied primary, modifying it for replicas

Throws:

Exception

indexOnReplica

public void indexOnReplica(org.opensearch.action.bulk.BulkShardRequest request,
 OpenSearchIndexLevelReplicationTestCase.ReplicationGroup group,
 org.opensearch.index.shard.IndexShard replica)
                    throws Exception

indexes the given requests on the supplied replica shard

Throws:

Exception