Package org.elasticsearch.cluster
Class ESAllocationTestCase
java.lang.Object
org.junit.Assert
org.apache.lucene.tests.util.LuceneTestCase
org.elasticsearch.test.ESTestCase
org.elasticsearch.cluster.ESAllocationTestCase
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionprotected static classMocks behavior in ReplicaShardAllocator to remove delayed shards from list of unassigned shards so they don't get reassigned yet.protected static classA lockAllocationServiceallowing tests to override timestatic classNested classes/interfaces inherited from class org.elasticsearch.test.ESTestCase
ESTestCase.DeprecationWarning, ESTestCase.GeohashGenerator, ESTestCase.TestAnalysis, ESTestCase.WithoutSecurityManagerNested classes/interfaces inherited from class org.apache.lucene.tests.util.LuceneTestCase
org.apache.lucene.tests.util.LuceneTestCase.AwaitsFix, org.apache.lucene.tests.util.LuceneTestCase.BadApple, 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
FieldsModifier and TypeFieldDescriptionprotected static Set<DiscoveryNodeRole> static final SnapshotsInfoServicestatic final WriteLoadForecasterFields inherited from class org.elasticsearch.test.ESTestCase
checkIndexFailures, DEFAULT_TEST_WORKER_ID, failureAndSuccessEvents, FIPS_SYSPROP, JAVA_TIMEZONE_IDS, JAVA_ZONE_IDS, logger, MIN_PRIVATE_PORT, SAFE_AWAIT_TIMEOUT, TEST_REQUEST_TIMEOUT, TEST_WORKER_SYS_PROPERTY, TEST_WORKER_VM_ID, UNSIGNED_LONG_MAXFields 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_BADAPPLES, SYSPROP_FAILFAST, SYSPROP_MAXFAILURES, SYSPROP_MONSTER, SYSPROP_NIGHTLY, 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_THROTTLING, TEST_WEEKLY, VERBOSE -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected ClusterStateapplyStartedShardsUntilNoChange(ClusterState clusterState, AllocationService service) createAllocationService(Settings settings) createAllocationService(Settings settings, ClusterInfoService clusterInfoService) createAllocationService(Settings settings, GatewayAllocator gatewayAllocator) createAllocationService(Settings settings, GatewayAllocator gatewayAllocator, ClusterInfoService clusterInfoService, SnapshotsInfoService snapshotsInfoService) createAllocationService(Settings settings, SnapshotsInfoService snapshotsInfoService) protected static ShardsAllocatorcreateShardsAllocator(Settings settings) protected static DiscoveryNodeprotected static DiscoveryNodeprotected static DiscoveryNodenewNode(String nodeName, String nodeId, Set<DiscoveryNodeRole> roles) protected static DiscoveryNodeprotected static DiscoveryNodenewNode(String nodeId, Set<DiscoveryNodeRole> roles) protected static DiscoveryNodeprotected static DiscoveryNodenewNode(String nodeId, Version version, IndexVersion indexVersion) protected static AllocationDecidersstatic AllocationDecidersrandomAllocationDeciders(Settings settings, ClusterSettings clusterSettings) static ClusterStatereroute(AllocationService allocationService, ClusterState clusterState) static ClusterStatestartInitializingShardsAndReroute(AllocationService allocationService, ClusterState state) Mark all initializing shards as started, then perform a reroute (which may start some other shards initializing).static ClusterStatestartInitializingShardsAndReroute(AllocationService allocationService, 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 ClusterStatestartInitializingShardsAndReroute(AllocationService allocationService, ClusterState clusterState, 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 ClusterStatestartRandomInitializingShard(ClusterState clusterState, AllocationService strategy) static ClusterStatestartShardsAndReroute(AllocationService allocationService, ClusterState clusterState, List<ShardRouting> initializingShards) Mark the given shards as started, then perform a reroute (which may start some other shards initializing).static ClusterStatestartShardsAndReroute(AllocationService allocationService, ClusterState clusterState, ShardRouting... initializingShards) Mark the given shards as started, then perform a reroute (which may start some other shards initializing).protected static AllocationDecidersprotected static AllocationDecidersMethods inherited from class org.elasticsearch.test.ESTestCase
after, afterIfFailed, afterIfSuccessful, allBreakersMemoryReleased, asInstanceOf, assertArrayEquals, assertBusy, assertBusy, assertCriticalWarnings, assertEquals, assertLeakDetected, assertSettingDeprecationsAndWarnings, assertThat, assertThat, assertWarnings, assertWarnings, before, between, buildEnvSettings, buildNewFakeTransportAddress, captureLoggingLevel, checkStaticState, compatibleMediaType, copyInstance, copyNamedWriteable, copyNamedWriteable, copyWriteable, copyWriteable, createDefaultIndexAnalyzers, createParser, createParser, createParser, createParser, createParser, createParser, createParserWithCompatibilityFor, createTestAnalysis, createTestAnalysis, createTestAnalysis, createThreadPool, enableBigArraysReleasedCheck, enableWarningsCheck, ensureAllContextsReleased, ensureAllSearchContextsReleased, ensureCheckIndexPassed, ensureNoWarnings, ensureSupportedLocale, expectThrows, expectThrows, fail, fail, filteredWarnings, flushThreadPoolExecutor, frequently, generateRandomStringArray, generateRandomStringArray, getDataPath, getPortRange, getResourceDataPath, getSuiteFailureMarker, getTestTransportPlugin, getTestTransportType, getWorkerBasePort, indexSettings, indexSettings, inFipsJvm, initTestSeed, isTurkishLocale, iterations, maybeRestoreClassSecurityManager, maybeSet, maybeStashClassSecurityManager, mockScript, newEnvironment, newEnvironment, newLimitedBreaker, newNodeEnvironment, newNodeEnvironment, parserConfig, randomAlphanumericOfLength, randomAlphaOfLength, randomAlphaOfLengthBetween, randomAlphaOfLengthOrNull, randomArray, randomArray, randomBigInteger, randomBoolean, randomByte, randomByteArrayOfLength, randomByteBetween, randomBytesBetween, randomByteSizeValue, randomBytesReference, randomCompatibleMediaType, randomDateFormatterPattern, randomDouble, randomDoubleBetween, randomDoubles, randomDoubles, randomExecutor, randomFloat, randomFloatBetween, randomFloatOrNull, randomFrom, randomFrom, randomFrom, randomFrom, randomFrom, randomFrom, randomGeohash, randomIdentifier, randomInstantBetween, randomInt, randomInt, randomIntBetween, randomIntOrNull, randomInts, randomInts, randomIp, randomList, randomList, randomLong, randomLongBetween, randomLongOrNull, randomLongs, randomLongs, randomMap, randomMillisUpToYear9999, randomNegativeInt, randomNonEmptySubsetOf, randomNonNegativeByte, randomNonNegativeInt, randomNonNegativeIntOrNull, randomNonNegativeLong, randomNonNegativeLongOrNull, randomOptionalBoolean, randomPositiveTimeValue, randomRealisticUnicodeOfCodepointLength, randomRealisticUnicodeOfCodepointLengthBetween, randomRealisticUnicodeOfLength, randomRealisticUnicodeOfLengthBetween, randomSecretKey, randomSecureStringOfLength, randomSet, randomShort, randomSubsetOf, randomSubsetOf, randomSubsetOf, randomTimeValue, randomTimeValue, randomTimeValue, randomTimeZone, randomUnicodeOfCodepointLength, randomUnicodeOfCodepointLengthBetween, randomUnicodeOfLength, randomUnicodeOfLengthBetween, randomUnique, randomUnsignedLongBetween, randomUUID, randomValueOtherThan, randomValueOtherThanMany, randomVendorType, randomZone, removeHeaderWarningAppender, resetCheckIndexStatus, resetPortCounter, restoreContentType, restoreFileSystem, restoreLoggingLevel, runInParallel, safeAcquire, safeAcquire, safeAwait, safeAwait, safeAwait, safeAwait, safeAwait, safeAwaitAndUnwrapFailure, safeAwaitFailure, safeAwaitFailure, safeAwaitFailure, safeAwaitFailure, safeExecute, safeGet, safeGet, safeSleep, safeSleep, scaledRandomIntBetween, secureRandom, secureRandom, secureRandomFips, secureRandomFips, secureRandomNonFips, secureRandomNonFips, setContentType, setFileSystem, setHeaderWarningAppender, settings, shuffledList, shuffleMap, shuffleXContent, shuffleXContent, skipTestWaitingForLuceneFix, spinForAtLeastNMilliseconds, spinForAtLeastOneMillisecond, startInParallel, terminate, terminate, tmpPaths, toShuffledXContent, waitUntil, waitUntil, writableRegistry, xContentRegistryMethods 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, 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, getDataInputStream, getJvmForkArguments, 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, 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, tearDown, usually, usually, wrapReaderMethods 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
-
Field Details
-
SNAPSHOT_INFO_SERVICE_WITH_NO_SHARD_SIZES
-
TEST_WRITE_LOAD_FORECASTER
-
MASTER_DATA_ROLES
-
-
Constructor Details
-
ESAllocationTestCase
public ESAllocationTestCase()
-
-
Method Details
-
createAllocationService
-
createAllocationService
-
createAllocationService
public static ESAllocationTestCase.MockAllocationService createAllocationService(Settings settings, GatewayAllocator gatewayAllocator) -
createAllocationService
public static ESAllocationTestCase.MockAllocationService createAllocationService(Settings settings, ClusterInfoService clusterInfoService) -
createAllocationService
public static ESAllocationTestCase.MockAllocationService createAllocationService(Settings settings, SnapshotsInfoService snapshotsInfoService) -
createAllocationService
public static ESAllocationTestCase.MockAllocationService createAllocationService(Settings settings, GatewayAllocator gatewayAllocator, ClusterInfoService clusterInfoService, SnapshotsInfoService snapshotsInfoService) -
randomAllocationDeciders
public static AllocationDeciders randomAllocationDeciders(Settings settings, ClusterSettings clusterSettings) -
createShardsAllocator
-
newNode
-
newNode
-
newNode
-
newNode
-
newNode
protected static DiscoveryNode newNode(String nodeName, String nodeId, Set<DiscoveryNodeRole> roles) -
newNode
-
newNode
-
startRandomInitializingShard
protected static ClusterState startRandomInitializingShard(ClusterState clusterState, AllocationService strategy) -
yesAllocationDeciders
-
noAllocationDeciders
-
throttleAllocationDeciders
-
applyStartedShardsUntilNoChange
protected ClusterState applyStartedShardsUntilNoChange(ClusterState clusterState, AllocationService service) -
startInitializingShardsAndReroute
public static ClusterState startInitializingShardsAndReroute(AllocationService allocationService, ClusterState state) 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 ClusterState startInitializingShardsAndReroute(AllocationService allocationService, ClusterState clusterState, 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 ClusterState startInitializingShardsAndReroute(AllocationService allocationService, 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 ClusterState startShardsAndReroute(AllocationService allocationService, ClusterState clusterState, 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 ClusterState startShardsAndReroute(AllocationService allocationService, ClusterState clusterState, List<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.
-
reroute
-