Class OpenSearchAllocationWithConstraintsTestCase

java.lang.Object

org.junit.Assert

org.apache.lucene.tests.util.LuceneTestCase

org.opensearch.test.OpenSearchTestCase

org.opensearch.cluster.OpenSearchAllocationTestCase

org.opensearch.cluster.OpenSearchAllocationWithConstraintsTestCase

public abstract class OpenSearchAllocationWithConstraintsTestCase
extends OpenSearchAllocationTestCase

Nested Class Summary

Nested classes/interfaces inherited from class org.opensearch.cluster.OpenSearchAllocationTestCase

OpenSearchAllocationTestCase.DelayedShardsMockGatewayAllocator, OpenSearchAllocationTestCase.MockAllocationService, OpenSearchAllocationTestCase.ShardAllocations, OpenSearchAllocationTestCase.TestAllocateDecision

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 OpenSearchAllocationTestCase.MockAllocationService	allocation
protected org.opensearch.cluster.ClusterState	clusterState

Fields inherited from class org.opensearch.cluster.OpenSearchAllocationTestCase

CLUSTER_MANAGER_DATA_ROLES, SEARCH_ROLE, SNAPSHOT_INFO_SERVICE_WITH_NO_SHARD_SIZES

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
OpenSearchAllocationWithConstraintsTestCase()

Method Summary

Modifier and Type	Method	Description
void	addIndices(String index_prefix, int indices, int shards, int replicas)
org.opensearch.cluster.node.DiscoveryNodes	addNodes(org.opensearch.cluster.node.DiscoveryNodes.Builder nb, String nodePrefix, int nodesAdded)
void	addNodesWithIndexing(int nodeCount, String node_prefix, int indices, int shards, int replicas)
void	addNodesWithoutIndexing(int nodeCount, String node_prefix)
int	allocateAndCheckIndexShardHotSpots(boolean expected, int nodes, String... nodesToValidate)
org.opensearch.cluster.ClusterState	allocateShardsAndBalance(org.opensearch.cluster.ClusterState clusterState)
void	assertForIndexShardHotSpots(boolean expected, int nodes, String... nodesToValidate)
void	buildAllocationService()
void	buildAllocationService(String excludeNodes)
void	buildAllocationService(org.opensearch.common.settings.Settings.Builder sb)
org.opensearch.cluster.metadata.Metadata	buildMetadata(org.opensearch.cluster.metadata.Metadata.Builder mb, String indexPrefix, int numberOfIndices, int numberOfShards, int numberOfReplicas)
void	buildNodeShardsByIndex()
org.opensearch.cluster.routing.RoutingTable	buildRoutingTable(org.opensearch.cluster.routing.RoutingTable.Builder rb, org.opensearch.cluster.metadata.Metadata metadata, String indexPrefix, int numberOfIndices)
void	buildZoneAwareAllocationService()
void	clearState()
void	createEmptyZoneAwareCluster(Map<String,Integer> nodesPerZone)
List<String>	getNodeList(String... nodesToValidate)
boolean	isIndexHotSpotPresent(int nodes, List<String> nodeList)
void	resetCluster()
void	setupInitialCluster(int nodeCount, int indices, int shards, int replicas)
static String	shardIdentifierFromRouting(org.opensearch.cluster.routing.ShardRouting shardRouting)
void	terminateNodes(String... nodesToTerminate)
void	updateInitialCluster()

Methods inherited from class org.opensearch.cluster.OpenSearchAllocationTestCase

allocationDecidersForExcludeAPI, applyStartedShardsUntilNoChange, createAllocationService, createAllocationService, createAllocationService, createAllocationService, createAllocationService, createAllocationService, createAllocationService, createAllocationService, newNode, newNode, newNode, newNode, newNode, newNode, newRoutingAllocation, newSearchNode, newSearchNode, newSearchNode, newSearchNode, noAllocationDeciders, randomAllocationDeciders, startInitializingShardsAndReroute, startInitializingShardsAndReroute, startInitializingShardsAndReroute, startRandomInitializingShard, startRandomInitializingShard, startShardsAndReroute, startShardsAndReroute, throttleAllocationDeciders, yesAllocationDeciders

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, tearDown, 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, setUp, 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

allocation

protected OpenSearchAllocationTestCase.MockAllocationService allocation

clusterState

protected org.opensearch.cluster.ClusterState clusterState

Constructor Details

OpenSearchAllocationWithConstraintsTestCase

public OpenSearchAllocationWithConstraintsTestCase()

Method Details

clearState

public void clearState()

shardIdentifierFromRouting

public static String shardIdentifierFromRouting(org.opensearch.cluster.routing.ShardRouting shardRouting)

buildAllocationService

public void buildAllocationService()

buildAllocationService

public void buildAllocationService(String excludeNodes)

buildZoneAwareAllocationService

public void buildZoneAwareAllocationService()

buildAllocationService

public void buildAllocationService(org.opensearch.common.settings.Settings.Builder sb)

buildMetadata

public org.opensearch.cluster.metadata.Metadata buildMetadata(org.opensearch.cluster.metadata.Metadata.Builder mb,
 String indexPrefix,
 int numberOfIndices,
 int numberOfShards,
 int numberOfReplicas)

buildRoutingTable

public org.opensearch.cluster.routing.RoutingTable buildRoutingTable(org.opensearch.cluster.routing.RoutingTable.Builder rb,
 org.opensearch.cluster.metadata.Metadata metadata,
 String indexPrefix,
 int numberOfIndices)

addNodes

public org.opensearch.cluster.node.DiscoveryNodes addNodes(org.opensearch.cluster.node.DiscoveryNodes.Builder nb,
 String nodePrefix,
 int nodesAdded)

resetCluster

public void resetCluster()

updateInitialCluster

public void updateInitialCluster()

createEmptyZoneAwareCluster

public void createEmptyZoneAwareCluster(Map<String,Integer> nodesPerZone)

setupInitialCluster

public void setupInitialCluster(int nodeCount,
 int indices,
 int shards,
 int replicas)

buildNodeShardsByIndex

public void buildNodeShardsByIndex()

isIndexHotSpotPresent

public boolean isIndexHotSpotPresent(int nodes,
 List<String> nodeList)

getNodeList

public List<String> getNodeList(String... nodesToValidate)

assertForIndexShardHotSpots

public void assertForIndexShardHotSpots(boolean expected,
 int nodes,
 String... nodesToValidate)

allocateAndCheckIndexShardHotSpots

public int allocateAndCheckIndexShardHotSpots(boolean expected,
 int nodes,
 String... nodesToValidate)

allocateShardsAndBalance

public org.opensearch.cluster.ClusterState allocateShardsAndBalance(org.opensearch.cluster.ClusterState clusterState)

addNodesWithoutIndexing

public void addNodesWithoutIndexing(int nodeCount,
 String node_prefix)

terminateNodes

public void terminateNodes(String... nodesToTerminate)

addNodesWithIndexing

public void addNodesWithIndexing(int nodeCount,
 String node_prefix,
 int indices,
 int shards,
 int replicas)

addIndices

public void addIndices(String index_prefix,
 int indices,
 int shards,
 int replicas)