Class AbstractCoordinatorTestCase

java.lang.Object

org.junit.Assert

org.apache.lucene.tests.util.LuceneTestCase

org.opensearch.test.OpenSearchTestCase

org.opensearch.cluster.coordination.AbstractCoordinatorTestCase

public class AbstractCoordinatorTestCase
extends OpenSearchTestCase

Nested Class Summary

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
static final long	DEFAULT_CLUSTER_STATE_UPDATE_DELAY
static final long	DEFAULT_ELECTION_DELAY
static final long	DEFAULT_STABILISATION_TIME
protected final AtomicInteger	nextNodeIndex
static final String	NODE_ID_LOG_CONTEXT_KEY
protected final List<org.opensearch.env.NodeEnvironment>	nodeEnvironments
protected final Set<org.opensearch.cluster.coordination.AbstractCoordinatorTestCase.Cluster.MockPersistedState>	openPersistedStates

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

Method Summary

Modifier and Type	Method	Description
void	assertAllPersistedStatesClosed()
void	assertStateEquals(org.opensearch.cluster.ClusterState clusterState1, org.opensearch.cluster.ClusterState clusterState2)
void	closeNodeEnvironmentsAfterEachTest()
protected org.opensearch.cluster.node.DiscoveryNode	createDiscoveryNode(int nodeIndex, boolean clusterManagerEligible)
static org.opensearch.cluster.NodeConnectionsService	createTestNodeConnectionsService(org.opensearch.common.settings.Settings settings, org.opensearch.threadpool.ThreadPool threadPool, org.opensearch.transport.TransportService transportService)
protected static int	defaultInt(org.opensearch.common.settings.Setting<Integer> setting)
protected static long	defaultMillis(org.opensearch.common.settings.Setting<org.opensearch.common.unit.TimeValue> setting)
protected org.opensearch.cluster.coordination.ElectionStrategy	getElectionStrategy()
protected static String	getNodeIdForLogContext(org.opensearch.cluster.node.DiscoveryNode node)
protected org.opensearch.transport.TransportInterceptor	getTransportInterceptor(org.opensearch.cluster.node.DiscoveryNode localNode, org.opensearch.threadpool.ThreadPool threadPool)
Set<Integer>	keySet(org.opensearch.cluster.ClusterState clusterState)
static Runnable	onNodeLog(org.opensearch.cluster.node.DiscoveryNode node, Runnable runnable)
void	resetNodeIndexBeforeEachTest()
void	resetPortCounterBeforeEachTest()
org.opensearch.cluster.ClusterState	setValue(org.opensearch.cluster.ClusterState clusterState, int key, long value)
void	testRegisterSpecConsistency()
void	testRepeatableTests()
long	value(org.opensearch.cluster.ClusterState clusterState)
long	value(org.opensearch.cluster.ClusterState clusterState, int key)

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

nodeEnvironments

protected final List<org.opensearch.env.NodeEnvironment> nodeEnvironments

openPersistedStates

protected final Set<org.opensearch.cluster.coordination.AbstractCoordinatorTestCase.Cluster.MockPersistedState> openPersistedStates

nextNodeIndex

protected final AtomicInteger nextNodeIndex

DEFAULT_CLUSTER_STATE_UPDATE_DELAY

public static final long DEFAULT_CLUSTER_STATE_UPDATE_DELAY

See Also:

• Constant Field Values

DEFAULT_ELECTION_DELAY

public static final long DEFAULT_ELECTION_DELAY

DEFAULT_STABILISATION_TIME

public static final long DEFAULT_STABILISATION_TIME

NODE_ID_LOG_CONTEXT_KEY

public static final String NODE_ID_LOG_CONTEXT_KEY

See Also:

• Constant Field Values

Constructor Details

AbstractCoordinatorTestCase

public AbstractCoordinatorTestCase()

Method Details

resetNodeIndexBeforeEachTest

public void resetNodeIndexBeforeEachTest()

closeNodeEnvironmentsAfterEachTest

public void closeNodeEnvironmentsAfterEachTest()

assertAllPersistedStatesClosed

public void assertAllPersistedStatesClosed()

resetPortCounterBeforeEachTest

public void resetPortCounterBeforeEachTest()

testRepeatableTests

public void testRepeatableTests()
                         throws Exception

Throws:

Exception

defaultMillis

protected static long defaultMillis(org.opensearch.common.settings.Setting<org.opensearch.common.unit.TimeValue> setting)

defaultInt

protected static int defaultInt(org.opensearch.common.settings.Setting<Integer> setting)

getTransportInterceptor

protected org.opensearch.transport.TransportInterceptor getTransportInterceptor(org.opensearch.cluster.node.DiscoveryNode localNode,
 org.opensearch.threadpool.ThreadPool threadPool)

getElectionStrategy

protected org.opensearch.cluster.coordination.ElectionStrategy getElectionStrategy()

getNodeIdForLogContext

protected static String getNodeIdForLogContext(org.opensearch.cluster.node.DiscoveryNode node)

onNodeLog

public static Runnable onNodeLog(org.opensearch.cluster.node.DiscoveryNode node,
 Runnable runnable)

createTestNodeConnectionsService

public static org.opensearch.cluster.NodeConnectionsService createTestNodeConnectionsService(org.opensearch.common.settings.Settings settings,
 org.opensearch.threadpool.ThreadPool threadPool,
 org.opensearch.transport.TransportService transportService)

createDiscoveryNode

protected org.opensearch.cluster.node.DiscoveryNode createDiscoveryNode(int nodeIndex,
 boolean clusterManagerEligible)

setValue

public org.opensearch.cluster.ClusterState setValue(org.opensearch.cluster.ClusterState clusterState,
 int key,
 long value)

value

public long value(org.opensearch.cluster.ClusterState clusterState)

value

public long value(org.opensearch.cluster.ClusterState clusterState,
 int key)

assertStateEquals

public void assertStateEquals(org.opensearch.cluster.ClusterState clusterState1,
 org.opensearch.cluster.ClusterState clusterState2)

keySet

public Set<Integer> keySet(org.opensearch.cluster.ClusterState clusterState)

testRegisterSpecConsistency

public void testRegisterSpecConsistency()