Class OpenSearchAllocationTestCase

java.lang.Object

org.junit.Assert

org.apache.lucene.tests.util.LuceneTestCase

org.opensearch.test.OpenSearchTestCase

org.opensearch.cluster.OpenSearchAllocationTestCase

Direct Known Subclasses:

OpenSearchAllocationWithConstraintsTestCase

public abstract class OpenSearchAllocationTestCase
extends OpenSearchTestCase

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	OpenSearchAllocationTestCase.DelayedShardsMockGatewayAllocator	Mocks behavior in ReplicaShardAllocator to remove delayed shards from list of unassigned shards so they don't get reassigned yet.
protected static class	OpenSearchAllocationTestCase.MockAllocationService	A lock AllocationService allowing tests to override time
static class	OpenSearchAllocationTestCase.ShardAllocations	Utility class to show shards distribution across nodes.
static class	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 static Set<org.opensearch.cluster.node.DiscoveryNodeRole>	CLUSTER_MANAGER_DATA_ROLES
protected static Set<org.opensearch.cluster.node.DiscoveryNodeRole>	SEARCH_ROLE
static final org.opensearch.snapshots.SnapshotsInfoService	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
OpenSearchAllocationTestCase()

Method Summary

Modifier and Type	Method	Description
protected static org.opensearch.cluster.routing.allocation.decider.AllocationDeciders	allocationDecidersForExcludeAPI(org.opensearch.common.settings.Settings settings)
protected org.opensearch.cluster.ClusterState	applyStartedShardsUntilNoChange(org.opensearch.cluster.ClusterState clusterState, org.opensearch.cluster.routing.allocation.AllocationService service)
static OpenSearchAllocationTestCase.MockAllocationService	createAllocationService()
static OpenSearchAllocationTestCase.MockAllocationService	createAllocationService(org.opensearch.common.settings.Settings settings)
static OpenSearchAllocationTestCase.MockAllocationService	createAllocationService(org.opensearch.common.settings.Settings settings, Random random)
static OpenSearchAllocationTestCase.MockAllocationService	createAllocationService(org.opensearch.common.settings.Settings settings, org.opensearch.cluster.ClusterInfoService clusterInfoService)
static OpenSearchAllocationTestCase.MockAllocationService	createAllocationService(org.opensearch.common.settings.Settings settings, org.opensearch.common.settings.ClusterSettings clusterSettings, Random random)
static OpenSearchAllocationTestCase.MockAllocationService	createAllocationService(org.opensearch.common.settings.Settings settings, org.opensearch.gateway.GatewayAllocator gatewayAllocator)
static OpenSearchAllocationTestCase.MockAllocationService	createAllocationService(org.opensearch.common.settings.Settings settings, org.opensearch.gateway.GatewayAllocator gatewayAllocator, org.opensearch.snapshots.SnapshotsInfoService snapshotsInfoService)
static OpenSearchAllocationTestCase.MockAllocationService	createAllocationService(org.opensearch.common.settings.Settings settings, org.opensearch.snapshots.SnapshotsInfoService snapshotsInfoService)
protected static org.opensearch.cluster.node.DiscoveryNode	newNode(String nodeId)
protected static org.opensearch.cluster.node.DiscoveryNode	newNode(String nodeName, String nodeId, Map<String,String> attributes)
protected static org.opensearch.cluster.node.DiscoveryNode	newNode(String nodeName, String nodeId, Set<org.opensearch.cluster.node.DiscoveryNodeRole> roles)
protected static org.opensearch.cluster.node.DiscoveryNode	newNode(String nodeId, Map<String,String> attributes)
protected static org.opensearch.cluster.node.DiscoveryNode	newNode(String nodeId, Set<org.opensearch.cluster.node.DiscoveryNodeRole> roles)
protected static org.opensearch.cluster.node.DiscoveryNode	newNode(String nodeId, org.opensearch.Version version)
protected org.opensearch.cluster.routing.allocation.RoutingAllocation	newRoutingAllocation(org.opensearch.cluster.routing.allocation.decider.AllocationDeciders deciders, org.opensearch.cluster.ClusterState state)
protected static org.opensearch.cluster.node.DiscoveryNode	newSearchNode(String nodeId)
protected static org.opensearch.cluster.node.DiscoveryNode	newSearchNode(String nodeName, String nodeId, Map<String,String> attributes)
protected static org.opensearch.cluster.node.DiscoveryNode	newSearchNode(String nodeId, Map<String,String> attributes)
protected static org.opensearch.cluster.node.DiscoveryNode	newSearchNode(String nodeId, org.opensearch.Version version)
protected static org.opensearch.cluster.routing.allocation.decider.AllocationDeciders	noAllocationDeciders()
static org.opensearch.cluster.routing.allocation.decider.AllocationDeciders	randomAllocationDeciders(org.opensearch.common.settings.Settings settings, org.opensearch.common.settings.ClusterSettings clusterSettings, Random random)
static org.opensearch.cluster.ClusterState	startInitializingShardsAndReroute(org.opensearch.cluster.routing.allocation.AllocationService allocationService, org.opensearch.cluster.ClusterState clusterState)	Mark all initializing shards as started, then perform a reroute (which may start some other shards initializing).
static org.opensearch.cluster.ClusterState	startInitializingShardsAndReroute(org.opensearch.cluster.routing.allocation.AllocationService allocationService, org.opensearch.cluster.ClusterState clusterState, String index)	Mark all initializing shards for the given index as started, then perform a reroute (which may start some other shards initializing).
static org.opensearch.cluster.ClusterState	startInitializingShardsAndReroute(org.opensearch.cluster.routing.allocation.AllocationService allocationService, org.opensearch.cluster.ClusterState clusterState, org.opensearch.cluster.routing.RoutingNode routingNode)	Mark all initializing shards on the given node as started, then perform a reroute (which may start some other shards initializing).
protected static org.opensearch.cluster.ClusterState	startRandomInitializingShard(org.opensearch.cluster.ClusterState clusterState, org.opensearch.cluster.routing.allocation.AllocationService strategy)
protected static org.opensearch.cluster.ClusterState	startRandomInitializingShard(org.opensearch.cluster.ClusterState clusterState, org.opensearch.cluster.routing.allocation.AllocationService strategy, String index)
static org.opensearch.cluster.ClusterState	startShardsAndReroute(org.opensearch.cluster.routing.allocation.AllocationService allocationService, org.opensearch.cluster.ClusterState clusterState, List<org.opensearch.cluster.routing.ShardRouting> initializingShards)	Mark the given shards as started, then perform a reroute (which may start some other shards initializing).
static org.opensearch.cluster.ClusterState	startShardsAndReroute(org.opensearch.cluster.routing.allocation.AllocationService allocationService, org.opensearch.cluster.ClusterState clusterState, org.opensearch.cluster.routing.ShardRouting... initializingShards)	Mark the given shards as started, then perform a reroute (which may start some other shards initializing).
protected static org.opensearch.cluster.routing.allocation.decider.AllocationDeciders	throttleAllocationDeciders()
protected static org.opensearch.cluster.routing.allocation.decider.AllocationDeciders	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

SNAPSHOT_INFO_SERVICE_WITH_NO_SHARD_SIZES

public static final org.opensearch.snapshots.SnapshotsInfoService SNAPSHOT_INFO_SERVICE_WITH_NO_SHARD_SIZES

CLUSTER_MANAGER_DATA_ROLES

protected static Set<org.opensearch.cluster.node.DiscoveryNodeRole> CLUSTER_MANAGER_DATA_ROLES

SEARCH_ROLE

protected static Set<org.opensearch.cluster.node.DiscoveryNodeRole> SEARCH_ROLE

Constructor Details

OpenSearchAllocationTestCase

public OpenSearchAllocationTestCase()

Method Details

createAllocationService

public static OpenSearchAllocationTestCase.MockAllocationService createAllocationService()

createAllocationService

public static OpenSearchAllocationTestCase.MockAllocationService createAllocationService(org.opensearch.common.settings.Settings settings)

createAllocationService

public static OpenSearchAllocationTestCase.MockAllocationService createAllocationService(org.opensearch.common.settings.Settings settings,
 Random random)

createAllocationService

public static OpenSearchAllocationTestCase.MockAllocationService createAllocationService(org.opensearch.common.settings.Settings settings,
 org.opensearch.common.settings.ClusterSettings clusterSettings,
 Random random)

createAllocationService

public static OpenSearchAllocationTestCase.MockAllocationService createAllocationService(org.opensearch.common.settings.Settings settings,
 org.opensearch.cluster.ClusterInfoService clusterInfoService)

createAllocationService

public static OpenSearchAllocationTestCase.MockAllocationService createAllocationService(org.opensearch.common.settings.Settings settings,
 org.opensearch.gateway.GatewayAllocator gatewayAllocator)

createAllocationService

public static OpenSearchAllocationTestCase.MockAllocationService createAllocationService(org.opensearch.common.settings.Settings settings,
 org.opensearch.snapshots.SnapshotsInfoService snapshotsInfoService)

createAllocationService

public static OpenSearchAllocationTestCase.MockAllocationService createAllocationService(org.opensearch.common.settings.Settings settings,
 org.opensearch.gateway.GatewayAllocator gatewayAllocator,
 org.opensearch.snapshots.SnapshotsInfoService snapshotsInfoService)

randomAllocationDeciders

public static org.opensearch.cluster.routing.allocation.decider.AllocationDeciders randomAllocationDeciders(org.opensearch.common.settings.Settings settings,
 org.opensearch.common.settings.ClusterSettings clusterSettings,
 Random random)

newNode

protected static org.opensearch.cluster.node.DiscoveryNode newNode(String nodeId)

newSearchNode

protected static org.opensearch.cluster.node.DiscoveryNode newSearchNode(String nodeId)

newSearchNode

protected static org.opensearch.cluster.node.DiscoveryNode newSearchNode(String nodeId,
 org.opensearch.Version version)

newSearchNode

protected static org.opensearch.cluster.node.DiscoveryNode newSearchNode(String nodeId,
 Map<String,String> attributes)

newSearchNode

protected static org.opensearch.cluster.node.DiscoveryNode newSearchNode(String nodeName,
 String nodeId,
 Map<String,String> attributes)

newNode

protected static org.opensearch.cluster.node.DiscoveryNode newNode(String nodeName,
 String nodeId,
 Map<String,String> attributes)

newNode

protected static org.opensearch.cluster.node.DiscoveryNode newNode(String nodeId,
 Map<String,String> attributes)

newNode

protected static org.opensearch.cluster.node.DiscoveryNode newNode(String nodeId,
 Set<org.opensearch.cluster.node.DiscoveryNodeRole> roles)

newNode

protected static org.opensearch.cluster.node.DiscoveryNode newNode(String nodeName,
 String nodeId,
 Set<org.opensearch.cluster.node.DiscoveryNodeRole> roles)

newNode

protected static org.opensearch.cluster.node.DiscoveryNode newNode(String nodeId,
 org.opensearch.Version version)

startRandomInitializingShard

protected static org.opensearch.cluster.ClusterState startRandomInitializingShard(org.opensearch.cluster.ClusterState clusterState,
 org.opensearch.cluster.routing.allocation.AllocationService strategy)

startRandomInitializingShard

protected static org.opensearch.cluster.ClusterState startRandomInitializingShard(org.opensearch.cluster.ClusterState clusterState,
 org.opensearch.cluster.routing.allocation.AllocationService strategy,
 String index)

yesAllocationDeciders

protected static org.opensearch.cluster.routing.allocation.decider.AllocationDeciders yesAllocationDeciders()

noAllocationDeciders

protected static org.opensearch.cluster.routing.allocation.decider.AllocationDeciders noAllocationDeciders()

throttleAllocationDeciders

protected static org.opensearch.cluster.routing.allocation.decider.AllocationDeciders throttleAllocationDeciders()

allocationDecidersForExcludeAPI

protected static org.opensearch.cluster.routing.allocation.decider.AllocationDeciders allocationDecidersForExcludeAPI(org.opensearch.common.settings.Settings settings)

applyStartedShardsUntilNoChange

protected org.opensearch.cluster.ClusterState applyStartedShardsUntilNoChange(org.opensearch.cluster.ClusterState clusterState,
 org.opensearch.cluster.routing.allocation.AllocationService service)

startInitializingShardsAndReroute

public static org.opensearch.cluster.ClusterState startInitializingShardsAndReroute(org.opensearch.cluster.routing.allocation.AllocationService allocationService,
 org.opensearch.cluster.ClusterState clusterState)

Mark all initializing shards as started, then perform a reroute (which may start some other shards initializing).

Returns:

the cluster state after completing the reroute.

startInitializingShardsAndReroute

public static org.opensearch.cluster.ClusterState startInitializingShardsAndReroute(org.opensearch.cluster.routing.allocation.AllocationService allocationService,
 org.opensearch.cluster.ClusterState clusterState,
 org.opensearch.cluster.routing.RoutingNode routingNode)

Mark all initializing shards on the given node as started, then perform a reroute (which may start some other shards initializing).

Returns:

the cluster state after completing the reroute.

startInitializingShardsAndReroute

public static org.opensearch.cluster.ClusterState startInitializingShardsAndReroute(org.opensearch.cluster.routing.allocation.AllocationService allocationService,
 org.opensearch.cluster.ClusterState clusterState,
 String index)

Mark all initializing shards for the given index as started, then perform a reroute (which may start some other shards initializing).

Returns:

the cluster state after completing the reroute.

startShardsAndReroute

public static org.opensearch.cluster.ClusterState startShardsAndReroute(org.opensearch.cluster.routing.allocation.AllocationService allocationService,
 org.opensearch.cluster.ClusterState clusterState,
 org.opensearch.cluster.routing.ShardRouting... initializingShards)

Mark the given shards as started, then perform a reroute (which may start some other shards initializing).

Returns:

the cluster state after completing the reroute.

startShardsAndReroute

public static org.opensearch.cluster.ClusterState startShardsAndReroute(org.opensearch.cluster.routing.allocation.AllocationService allocationService,
 org.opensearch.cluster.ClusterState clusterState,
 List<org.opensearch.cluster.routing.ShardRouting> initializingShards)

Mark the given shards as started, then perform a reroute (which may start some other shards initializing).

Returns:

the cluster state after completing the reroute.

newRoutingAllocation

protected org.opensearch.cluster.routing.allocation.RoutingAllocation newRoutingAllocation(org.opensearch.cluster.routing.allocation.decider.AllocationDeciders deciders,
 org.opensearch.cluster.ClusterState state)