Package org.elasticsearch.test
Class ESSingleNodeTestCase
java.lang.Object
org.junit.Assert
org.apache.lucene.tests.util.LuceneTestCase
org.elasticsearch.test.ESTestCase
org.elasticsearch.test.ESSingleNodeTestCase
- Direct Known Subclasses:
AbstractThirdPartyRepositoryTestCase,BasePointShapeQueryTestCase,NativeArrayIntegrationTestCase
A test that keep a singleton node started for all tests that can be used to get
references to Guice injectors in unit tests.
-
Nested Class Summary
Nested classes/interfaces inherited from class org.elasticsearch.test.ESTestCase
ESTestCase.DeprecationWarning, ESTestCase.EntitledTestPackages, ESTestCase.GeohashGenerator, ESTestCase.TestAnalysis, ESTestCase.WithEntitlementsOnTestCode, ESTestCase.WithoutEntitlementsNested 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 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_ENTITLEMENTS, 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_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 -
Method Summary
Modifier and TypeMethodDescriptionprotected booleanTrue if a dummy http transport should be used, or false if the real http transport should be used.protected AdminClientadmin()Returns an admin client.protected voidclient()Returns a client to the single-node cluster.protected ClusterAdminClientReturns a cluster admin client.protected IndexServicecreateIndex(String index) Create a new index on the singleton node with empty index settings.protected IndexServicecreateIndex(String index, CreateIndexRequestBuilder createIndexRequestBuilder) protected IndexServicecreateIndex(String index, Settings settings) Create a new index on the singleton node with the provided index settings.protected IndexServicecreateIndex(String index, Settings settings, String type, String... mappings) Create a new index on the singleton node with the provided index settings.protected IndexServicecreateIndex(String index, Settings settings, org.elasticsearch.xcontent.XContentBuilder mappings) Create a new index on the singleton node with the provided index settings.protected SearchContextcreateSearchContext(IndexService indexService) Create a new search context.protected final voiddeletePipeline(String id) Delete the ingest pipeline with the givenid, the defaultclient().protected booleanWhether we'd like to enable inter-segment search concurrency and increase the likelihood of leveraging it, by creating multiple slices with a low amount of documents in them, which would not be allowed in production.protected voidwaits until all free_context actions have been handled by the generic thread poolensureGreen(String... indices) Ensures the cluster has a green state via the cluster health API.ensureGreen(org.elasticsearch.core.TimeValue timeout, String... indices) Ensures the cluster has a green state via the cluster health API.protected voidwaits until all shard initialization is completed.protected booleanprotected <T> TgetInstanceFromNode(Class<T> clazz) Get an instance for a particular class using the injector of the singleton node.protected Collection<Class<? extends Plugin>> The plugin classes that should be added to the node.protected IndicesAdminClientReturns an indices admin client.protected Nodenode()Return a reference to the singleton node.protected SettingsAdditional settings to add when creating the node.protected final Collection<Class<? extends Plugin>> pluginList(Class<? extends Plugin>... plugins) Helper method to create list of plugins without specifying generic types.protected IndexRequestBuilderprepareIndex(String index) protected final voidputJsonPipeline(String id, String jsonString) Create an ingest pipeline with the given ID and body, using the defaultclient().protected final voidputJsonPipeline(String id, org.elasticsearch.xcontent.ToXContentFragment toXContent) Create an ingest pipeline with the given ID and body, using the defaultclient().protected booleanThis method returnstrueif the node that is used in the background should be reset after each test.resolveIndex(String index) <T extends ActionResponse>
TsafeExecute(ActionType<T> action, ActionRequest request) Execute the givenActionRequestusing the givenActionTypeand the default node client, wait for it to complete with a timeout ofESTestCase.SAFE_AWAIT_TIMEOUT, and then return the result.voidsetUp()static voidprotected voidstartNode(long seed) voidtearDown()static voidprotected voidupdateClusterSettings(Settings settings) wrapClient(Client client) protected org.elasticsearch.xcontent.NamedXContentRegistryTheNamedXContentRegistryto use for this test.Methods 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, expectThrows, expectThrows, fail, fail, flushThreadPoolExecutor, frequently, generateRandomStringArray, generateRandomStringArray, getDataPath, getPortRange, getResourceDataPath, getSuiteFailureMarker, getTestTransportPlugin, getTestTransportType, getWorkerBasePort, indexSettings, indexSettings, indexSettings, inFipsJvm, initTestSeed, isTurkishLocale, iterations, maybeSet, mockScript, newEnvironment, newEnvironment, newLimitedBreaker, newNodeEnvironment, newNodeEnvironment, newSearcher, newSearcher, newSearcher, newSearcher, parserConfig, projectStateFromProject, projectStateWithEmptyProject, 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, randomNegativeLong, randomNonEmptySubsetOf, randomNonNegativeByte, randomNonNegativeInt, randomNonNegativeIntOrNull, randomNonNegativeLong, randomNonNegativeLongOrNull, randomOptionalBoolean, randomPositiveTimeValue, randomProjectIdOrDefault, randomRealisticUnicodeOfCodepointLength, randomRealisticUnicodeOfCodepointLengthBetween, randomRealisticUnicodeOfLength, randomRealisticUnicodeOfLengthBetween, randomReleasableBytesReference, randomSecretKey, randomSecureStringOfLength, randomSet, randomShort, randomSubsetOf, randomSubsetOf, randomSubsetOf, randomTimeValue, randomTimeValue, randomTimeValue, randomTimeZone, randomUnicodeOfCodepointLength, randomUnicodeOfCodepointLengthBetween, randomUnicodeOfLength, randomUnicodeOfLengthBetween, randomUnique, randomUniqueProjectId, randomUnsignedLongBetween, randomUUID, randomValueOtherThan, randomValueOtherThanMany, randomVendorType, randomZone, removeHeaderWarningAppender, resetCheckIndexStatus, resetPortCounter, restoreContentType, restoreFileSystem, restoreLoggingLevel, runInParallel, safeAcquire, safeAcquire, safeAwait, 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, toShuffledXContent, waitUntil, waitUntil, writableRegistryMethods 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, 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, newSnapshotIndexWriterConfig, newStringField, newStringField, newStringField, newStringField, newTextField, newTextField, newTieredMergePolicy, newTieredMergePolicy, overrideDefaultQueryCache, overrideTestDefaultQueryCache, random, randomLocale, randomTimeZone, randomVectorFormat, rarely, rarely, replaceMaxFailureRule, resetDefaultQueryCache, restoreCPUCoreCount, restoreIndexWriterMaxDocs, runWithRestrictedPermissions, setIndexWriterMaxDocs, setupCPUCoreCount, setUpExecutorService, shutdownExecutorService, slowFileExists, 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
-
Constructor Details
-
ESSingleNodeTestCase
public ESSingleNodeTestCase()
-
-
Method Details
-
startNode
- Throws:
Exception
-
setUp
- Overrides:
setUpin classorg.apache.lucene.tests.util.LuceneTestCase- Throws:
Exception
-
tearDown
- Overrides:
tearDownin classorg.apache.lucene.tests.util.LuceneTestCase- Throws:
Exception
-
setUpClass
- Throws:
Exception
-
tearDownClass
- Throws:
Exception
-
resetNodeAfterTest
protected boolean resetNodeAfterTest()This method returnstrueif the node that is used in the background should be reset after each test. This is useful if the test changes the cluster state metadata etc. The default isfalse. -
getPlugins
The plugin classes that should be added to the node. -
pluginList
@SafeVarargs protected final Collection<Class<? extends Plugin>> pluginList(Class<? extends Plugin>... plugins) Helper method to create list of plugins without specifying generic types. -
nodeSettings
Additional settings to add when creating the node. Also allows overriding the default settings. -
addMockHttpTransport
protected boolean addMockHttpTransport()True if a dummy http transport should be used, or false if the real http transport should be used. -
filteredWarnings
- Overrides:
filteredWarningsin classESTestCase
-
client
Returns a client to the single-node cluster. -
safeExecute
Execute the givenActionRequestusing the givenActionTypeand the default node client, wait for it to complete with a timeout ofESTestCase.SAFE_AWAIT_TIMEOUT, and then return the result. An exceptional response, timeout or interrupt triggers a test failure. -
admin
Returns an admin client. -
indicesAdmin
Returns an indices admin client. -
clusterAdmin
Returns a cluster admin client. -
wrapClient
-
node
Return a reference to the singleton node. -
getInstanceFromNode
Get an instance for a particular class using the injector of the singleton node. -
createIndex
Create a new index on the singleton node with empty index settings. -
createIndex
Create a new index on the singleton node with the provided index settings. -
createIndex
protected IndexService createIndex(String index, Settings settings, org.elasticsearch.xcontent.XContentBuilder mappings) Create a new index on the singleton node with the provided index settings. -
createIndex
protected IndexService createIndex(String index, Settings settings, String type, String... mappings) Create a new index on the singleton node with the provided index settings. -
createIndex
protected IndexService createIndex(String index, CreateIndexRequestBuilder createIndexRequestBuilder) -
resolveIndex
-
prepareIndex
-
createSearchContext
Create a new search context. -
ensureGreen
Ensures the cluster has a green state via the cluster health API. This method will also wait for relocations. It is useful to ensure that all action on the cluster have finished and all shards that were currently relocating are now allocated and started. -
ensureGreen
Ensures the cluster has a green state via the cluster health API. This method will also wait for relocations. It is useful to ensure that all action on the cluster have finished and all shards that were currently relocating are now allocated and started.- Parameters:
timeout- time out value to set onClusterHealthRequest
-
xContentRegistry
protected org.elasticsearch.xcontent.NamedXContentRegistry xContentRegistry()Description copied from class:ESTestCaseTheNamedXContentRegistryto use for this test. Subclasses should override and use liberally.- Overrides:
xContentRegistryin classESTestCase
-
forbidPrivateIndexSettings
protected boolean forbidPrivateIndexSettings() -
ensureNoInitializingShards
protected void ensureNoInitializingShards()waits until all shard initialization is completed. inspired byESRestTestCase -
ensureAllFreeContextActionsAreConsumed
waits until all free_context actions have been handled by the generic thread pool- Throws:
Exception
-
enableConcurrentSearch
protected boolean enableConcurrentSearch()Whether we'd like to enable inter-segment search concurrency and increase the likelihood of leveraging it, by creating multiple slices with a low amount of documents in them, which would not be allowed in production. Default is true, can be disabled if it causes problems in specific tests. -
awaitIndexShardCloseAsyncTasks
protected void awaitIndexShardCloseAsyncTasks() -
putJsonPipeline
Create an ingest pipeline with the given ID and body, using the defaultclient().- Parameters:
id- The pipeline id.jsonString- The body of thePutPipelineRequestas a JSON-formattedString.
-
putJsonPipeline
protected final void putJsonPipeline(String id, org.elasticsearch.xcontent.ToXContentFragment toXContent) throws IOException Create an ingest pipeline with the given ID and body, using the defaultclient().- Parameters:
id- The pipeline id.toXContent- The body of thePutPipelineRequestas aToXContentFragment.- Throws:
IOException
-
deletePipeline
Delete the ingest pipeline with the givenid, the defaultclient(). -
updateClusterSettings
-