Package org.opensearch.index.replication

Class OpenSearchIndexLevelReplicationTestCase

java.lang.Object

org.junit.Assert

org.apache.lucene.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.GeohashGenerator, OpenSearchTestCase.TestAnalysis

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

org.apache.lucene.util.LuceneTestCase.AwaitsFix, org.apache.lucene.util.LuceneTestCase.BadApple, org.apache.lucene.util.LuceneTestCase.Monster, org.apache.lucene.util.LuceneTestCase.Nightly, org.apache.lucene.util.LuceneTestCase.Slow, org.apache.lucene.util.LuceneTestCase.SuppressCodecs, org.apache.lucene.util.LuceneTestCase.SuppressFileSystems, org.apache.lucene.util.LuceneTestCase.SuppressFsync, org.apache.lucene.util.LuceneTestCase.SuppressReproduceLine, org.apache.lucene.util.LuceneTestCase.SuppressSysoutChecks, org.apache.lucene.util.LuceneTestCase.SuppressTempFileChecks, org.apache.lucene.util.LuceneTestCase.ThrowingRunnable, org.apache.lucene.util.LuceneTestCase.Weekly

Field Summary

Fields

Modifier and Type	Field	Description
protected org.opensearch.index.Index	index
protected java.util.Map<java.lang.String,java.lang.String>	indexMapping

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

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, FIPS_SYSPROP, 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.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_BADAPPLES, SYSPROP_FAILFAST, SYSPROP_MAXFAILURES, SYSPROP_MONSTER, SYSPROP_NIGHTLY, SYSPROP_SLOW, SYSPROP_WEEKLY, TEST_ASSERTS_ENABLED, TEST_AWAITSFIX, TEST_BADAPPLES, TEST_CODEC, TEST_DIRECTORY, TEST_DOCVALUESFORMAT, TEST_LINE_DOCS_FILE, TEST_MONSTER, TEST_NIGHTLY, TEST_POSTINGSFORMAT, TEST_SLOW, 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, java.util.Map<java.lang.String,java.lang.String> mappings)
protected org.opensearch.cluster.metadata.IndexMetadata	buildIndexMetadata(int replicas, org.opensearch.common.settings.Settings indexSettings, java.util.Map<java.lang.String,java.lang.String> mappings)
protected OpenSearchIndexLevelReplicationTestCase.ReplicationGroup	createGroup(int replicas)
protected OpenSearchIndexLevelReplicationTestCase.ReplicationGroup	createGroup(int replicas, org.opensearch.common.settings.Settings settings)
protected org.opensearch.cluster.node.DiscoveryNode	getDiscoveryNode(java.lang.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

allowShardFailures, assertConsistentHistoryBetweenTranslogAndLucene, assertDocCount, assertDocs, closeShard, closeShards, closeShards, createStore, createStore, createTestWarmer, deleteDoc, failOnShardFailures, flushShard, flushShard, getDocIdAndSeqNos, getEngine, getFakeDiscoNode, getReplicationTracker, getShardDocUIDs, getTranslog, indexDoc, indexDoc, indexDoc, newShard, newShard, newShard, newShard, newShard, newShard, newShard, newShard, newShard, newShard, newShard, newShard, newStartedShard, newStartedShard, newStartedShard, newStartedShard, newStartedShard, newStartedShard, promoteReplica, recoverFromStore, recoverReplica, recoverReplica, recoverShardFromSnapshot, recoverShardFromStore, recoverUnstartedReplica, recoveryEmptyReplica, reinitShard, reinitShard, reinitShard, setUp, setUpThreadPool, snapshotShard, startReplicaAfterRecovery, tearDown, tearDownThreadPool, threadPoolSettings, updateMappings, updateRoutingEntry

Methods inherited from class org.opensearch.test.OpenSearchTestCase

after, afterIfFailed, afterIfSuccessful, allowedWarnings, assertArrayEquals, assertBusy, assertBusy, assertEquals, 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, getDataPath, getPortRange, getSuiteFailureMarker, getTestTransportPlugin, getTestTransportType, inFipsJvm, iterations, maybeSet, mockScript, newNodeEnvironment, newNodeEnvironment, 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, randomNonNegativeLong, randomPositiveTimeValue, randomRealisticUnicodeOfCodepointLength, randomRealisticUnicodeOfCodepointLengthBetween, randomRealisticUnicodeOfLength, randomRealisticUnicodeOfLengthBetween, randomShort, randomSubsetOf, randomSubsetOf, randomSubsetOf, randomTimeValue, randomTimeValue, randomTimeValue, randomTimeZone, randomUnicodeOfCodepointLength, randomUnicodeOfCodepointLengthBetween, randomUnicodeOfLength, randomUnicodeOfLengthBetween, randomUnique, randomValueOtherThan, randomValueOtherThanMany, randomZone, removeHeaderWarningAppender, resetCheckIndexStatus, resetPortCounter, restoreContentType, restoreFileSystem, scaledRandomIntBetween, setContentType, setFileSystem, setHeaderWarningAppender, settings, shuffleMap, shuffleXContent, shuffleXContent, spinForAtLeastNMilliseconds, spinForAtLeastOneMillisecond, terminate, terminate, tmpPaths, toShuffledXContent, waitUntil, waitUntil, writableRegistry, xContentRegistry

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

addVirusChecker, assertDeletedDocsEquals, assertDocsAndPositionsEnumEquals, assertDocsEnumEquals, assertDocsSkippingEquals, assertDocValuesEquals, assertDocValuesEquals, assertFieldInfosEquals, assertNormsEquals, assertPointsEquals, assertPositionsSkippingEquals, assertReaderEquals, assertReaderStatisticsEquals, assertStoredFieldEquals, assertStoredFieldsEquals, assertTermsEnumEquals, assertTermsEquals, assertTermsEquals, assertTermsStatisticsEquals, assertTermStatsEquals, assertTermVectorsEquals, asSet, assumeFalse, assumeNoException, assumeTrue, assumeWorkingMMapOnWindows, atLeast, atLeast, callStackContains, callStackContains, callStackContainsAnyOf, closeAfterSuite, closeAfterTest, collate, createTempDir, createTempDir, createTempFile, createTempFile, dumpArray, dumpIterator, ensureSaneIWCOnNightly, expectThrows, expectThrows, expectThrows, expectThrowsAnyOf, expectThrowsAnyOf, getBaseTempDirForTestClass, getDataInputStream, getOnlyLeafReader, getTestClass, getTestName, hasWorkingMMapOnWindows, 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, newStringField, newStringField, newStringField, newStringField, newTextField, newTextField, newTieredMergePolicy, newTieredMergePolicy, overrideDefaultQueryCache, overrideTestDefaultQueryCache, random, randomLocale, randomTimeZone, rarely, rarely, replaceMaxFailureRule, resetDefaultQueryCache, restoreCPUCoreCount, restoreIndexWriterMaxDocs, restoreSpins, runWithRestrictedPermissions, setIndexWriterMaxDocs, setupCPUCoreCount, setupSpins, 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, assertThat, assertThat, 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.index.Index index

indexMapping

protected final java.util.Map<java.lang.String,java.lang.String> indexMapping

Constructor Details

OpenSearchIndexLevelReplicationTestCase

public OpenSearchIndexLevelReplicationTestCase()

Method Details

createGroup

protected OpenSearchIndexLevelReplicationTestCase.ReplicationGroup createGroup(int replicas) throws java.io.IOException

Throws:

java.io.IOException

createGroup

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

Throws:

java.io.IOException

buildIndexMetadata

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

Throws:

java.io.IOException

buildIndexMetadata

protected org.opensearch.cluster.metadata.IndexMetadata buildIndexMetadata(int replicas, java.util.Map<java.lang.String,java.lang.String> mappings) throws java.io.IOException

Throws:

java.io.IOException

buildIndexMetadata

protected org.opensearch.cluster.metadata.IndexMetadata buildIndexMetadata(int replicas, org.opensearch.common.settings.Settings indexSettings, java.util.Map<java.lang.String,java.lang.String> mappings) throws java.io.IOException

Throws:

java.io.IOException

getDiscoveryNode

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

indexOnPrimary

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

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

Throws:

java.lang.Exception

indexOnReplica

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

indexes the given requests on the supplied replica shard

Throws:

java.lang.Exception