Class RemoteStoreCoreTestCase

java.lang.Object

org.junit.Assert

org.apache.lucene.tests.util.LuceneTestCase

org.opensearch.test.OpenSearchTestCase

org.opensearch.test.OpenSearchIntegTestCase

org.opensearch.remotestore.RemoteStoreBaseIntegTestCase

org.opensearch.remotestore.RemoteStoreCoreTestCase

public class RemoteStoreCoreTestCase
extends RemoteStoreBaseIntegTestCase

Nested Class Summary

Nested classes/interfaces inherited from class org.opensearch.test.OpenSearchIntegTestCase

OpenSearchIntegTestCase.AssertActionNamePlugin, OpenSearchIntegTestCase.ClusterScope, OpenSearchIntegTestCase.NumShards, OpenSearchIntegTestCase.Scope, OpenSearchIntegTestCase.SuiteScopeTestCase, OpenSearchIntegTestCase.TestSeedPlugin, OpenSearchIntegTestCase.ThirdParty

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 final String	INDEX_NAME

Fields inherited from class org.opensearch.remotestore.RemoteStoreBaseIntegTestCase

asyncUploadMockFsRepo, clusterSettingsSuppliedByTest, MAX_SEQ_NO_REFRESHED_OR_FLUSHED, MAX_SEQ_NO_TOTAL, REFRESHED_OR_FLUSHED_OPERATIONS, REMOTE_ROUTING_TABLE_REPO, REPLICA_COUNT, REPOSITORY_2_NAME, REPOSITORY_3_NAME, REPOSITORY_NAME, segmentRepoPath, SHARD_COUNT, TOTAL_OPERATIONS, translogRepoPath

Fields inherited from class org.opensearch.test.OpenSearchIntegTestCase

CODECS, DEFAULT_MAX_NUM_SHARDS, DEFAULT_MIN_NUM_SHARDS, INDEX_TEST_SEED_SETTING, prefixModeVerificationEnable, REMOTE_BACKED_STORAGE_REPOSITORY_NAME, segmentsPathFixedPrefix, snapshotShardPathFixedPrefix, SUITE_CLUSTER_NODE_PREFIX, SYSPROP_THIRDPARTY, TEST_CLUSTER_NODE_PREFIX, testClusterRule, TESTS_CLUSTER, TESTS_CLUSTER_NAME, TESTS_ENABLE_MOCK_MODULES, translogPathFixedPrefix

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

Method Summary

Modifier and Type	Method	Description
protected void	delete(Path baseRepoPath, String shardPath)
protected int	getActualFileCount(Path segmentRepoPath, String shardPath)
protected org.opensearch.common.blobstore.BlobPath	getSegmentBasePath()
org.opensearch.common.settings.Settings	indexSettings()	Returns a settings object used in OpenSearchIntegTestCase.createIndex(String...) and OpenSearchIntegTestCase.prepareCreate(String) and friends.
protected Collection<Class<? extends org.opensearch.plugins.Plugin>>	nodePlugins()	Returns a collection of plugins that should be loaded on each node.
void	testAsyncDurabilityThrowsExceptionWhenRestrictSettingTrue()
void	testAsyncDurabilityWhenRestrictSettingExplicitFalse()
void	testAsyncDurabilityWhenRestrictSettingImplicitFalse()
void	testAsyncTranslogDurabilityRestrictionsThroughIdxTemplates()
void	testCloseIndexWithNoOpSyncAndFlushForAsyncTranslog()
void	testCloseIndexWithNoOpSyncAndFlushForSyncTranslog()
void	testClusterBufferIntervalValidation()	This tests validation of the cluster setting when being set.
void	testDefaultBufferInterval()	Tests that when the index setting is not passed during index creation, the buffer interval picked up is the cluster default.
void	testFallbackToNodeToNodeSegmentCopy()
void	testFlushOnTooManyRemoteTranslogFiles()
void	testLocalOnlyTranslogCleanupOnNodeRestart()
void	testNoMultipleWriterDuringPrimaryRelocation()
void	testNoSearchIdleForAnyReplicaCount()
void	testOverriddenBufferInterval()	This tests multiple cases where the index setting is passed during the index creation with multiple combinations with and without cluster default.
void	testOverriddenBufferIntervalValidation()	This tests validation which kicks in during index creation failing creation if the value is less than minimum allowed value.
void	testPeerRecoveryWithLowActivityTimeout()
void	testPeerRecoveryWithRemoteStoreAndRemoteTranslogFlush()
void	testPeerRecoveryWithRemoteStoreAndRemoteTranslogNoDataFlush()
void	testPeerRecoveryWithRemoteStoreAndRemoteTranslogNoDataRefresh()
void	testPeerRecoveryWithRemoteStoreAndRemoteTranslogRefresh()
void	testRemoteStoreIndexCreationAndDeletionWithReferencedStore()
void	testRemoteTranslogCleanup()
void	testRequestDurabilityWhenRestrictSettingExplicitFalse()
void	testRequestDurabilityWhenRestrictSettingImplicitFalse()
void	testRestoreSnapshotToIndexWithSameNameDifferentUUID()
void	testResumeUploadAfterFailedPrimaryRelocation()
void	testStaleCommitDeletionWithInvokeFlush()
void	testStaleCommitDeletionWithMinSegmentFiles_3()
void	testStaleCommitDeletionWithMinSegmentFiles_Disabled()
void	testStaleCommitDeletionWithoutInvokeFlush()
void	testSuccessfulShallowV1SnapshotPostIndexClose()

Methods inherited from class org.opensearch.remotestore.RemoteStoreBaseIntegTestCase

assertRemoteStoreRepositoryOnAllNodes, buildRepositoryMetadata, getFileCount, getIndexShard, getIndexShardFromShardId, indexBulk, indexData, indexData, indexSingleDoc, indexSingleDoc, nodeSettings, prepareCluster, prepareCluster, prepareCluster, remoteStoreIndexSettings, remoteStoreIndexSettings, remoteStoreIndexSettings, remoteStoreRepoSettings, restore, setFailRate, teardown

Methods inherited from class org.opensearch.test.OpenSearchIntegTestCase

additionalNodePlugins, addMockGeoShapeFieldMapper, addMockHttpTransport, addMockIndexStorePlugin, addMockInternalEngine, addMockTelemetryPlugin, addMockTransportService, admin, afterClass, allowNodes, assertAllShardsOnNodes, assertResultsAndLogOnFailure, assertSortedSegments, beforeClass, beforeIndexDeletion, buildRemotePublicationNodeAttributes, buildRemoteStateNodeAttributes, buildRemoteStoreNodeAttributes, buildRemoteStoreNodeAttributes, buildRemoteStoreNodeAttributes, buildTestCluster, clearScroll, client, client, clients, cluster, clusterAdmin, clusterService, createIndex, createIndex, createIndex, createIndex, createRepository, createRepository, dataNodeClient, disableAllocation, disableIndexBlock, enableAllocation, enableIndexBlock, enableWarningsCheck, ensureClusterSizeConsistency, ensureClusterStateCanBeReadByNodeTool, ensureClusterStateConsistency, ensureFullyConnectedCluster, ensureGreen, ensureGreen, ensureGreen, ensureRed, ensureSearchable, ensureStableCluster, ensureStableCluster, ensureStableCluster, ensureStableCluster, ensureYellow, ensureYellowAndNoInitializingShards, excludeTemplates, externalClusterClientSettings, featureFlagSettings, flush, flushAndRefresh, forbidPrivateIndexSettings, forceMerge, forceMerge, getClientWrapper, getClusterState, getIndexShard, getIndexShard, getLatestSegmentInfoVersion, getMockPlugins, getNodeSettings, getNumShards, getRestClient, ignoreExternalCluster, index, index, index, index, index, indexExists, indexRandom, indexRandom, indexRandom, indexRandom, indexRandom, indexRandomForMultipleSlices, internalCluster, isInternalCluster, isMigratingToRemoteStore, isolateClusterManagerDisruption, isSegmentReplicationEnabledForIndex, logClusterState, manageReplicaBalanceSetting, manageReplicaSettingForDefaultReplica, maximumNumberOfReplicas, maximumNumberOfShards, minimumNumberOfReplicas, minimumNumberOfShards, nodeConfigPath, numberOfReplicas, numberOfShards, performRemoteStoreTestAction, prepareCreate, prepareCreate, prepareCreate, prepareCreate, primaryNodeName, primaryNodeName, putRepository, putRepository, putRepository, putRepository, putRepositoryRequestBuilder, putRepositoryWithNoSettingOverrides, randomIndexTemplate, randomRepoPath, randomRepoPath, refresh, refreshAndWaitForReplication, remoteStoreClusterSettings, remoteStoreClusterSettings, remoteStoreClusterSettings, remoteStoreClusterSettings, remoteStoreClusterSettings, replicaNodeName, resolveCustomDataPath, resolveIndex, resolvePath, routingKeyForShard, setClusterReadOnly, setDisruptionScheme, setRandomIndexSettings, setupSuiteScopeCluster, triggerRemoteStateRestore, updateRepository, useRandomReplicationStrategy, waitForDocs, waitForIndexed, waitForRelocation, waitForRelocation, waitForReplication, waitNoPendingTasksOnAll, willSufferDebian8MemoryProblem, xContentRegistry

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

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

INDEX_NAME

protected final String INDEX_NAME

See Also:

• Constant Field Values

Constructor Details

RemoteStoreCoreTestCase

public RemoteStoreCoreTestCase()

Method Details

nodePlugins

protected Collection<Class<? extends org.opensearch.plugins.Plugin>> nodePlugins()

Description copied from class: OpenSearchIntegTestCase

Returns a collection of plugins that should be loaded on each node.

Overrides:

nodePlugins in class RemoteStoreBaseIntegTestCase

indexSettings

public org.opensearch.common.settings.Settings indexSettings()

Description copied from class: OpenSearchIntegTestCase

Returns a settings object used in OpenSearchIntegTestCase.createIndex(String...) and OpenSearchIntegTestCase.prepareCreate(String) and friends. This method can be overwritten by subclasses to set defaults for the indices that are created by the test. By default it returns a settings object that sets a random number of shards. Number of shards and replicas can be controlled through specific methods.

Overrides:

indexSettings in class RemoteStoreBaseIntegTestCase

testRemoteStoreIndexCreationAndDeletionWithReferencedStore

public void testRemoteStoreIndexCreationAndDeletionWithReferencedStore()
                                                                throws InterruptedException,
ExecutionException

Throws:

InterruptedException

ExecutionException

testPeerRecoveryWithRemoteStoreAndRemoteTranslogNoDataFlush

public void testPeerRecoveryWithRemoteStoreAndRemoteTranslogNoDataFlush()
                                                                 throws Exception

Throws:

Exception

testPeerRecoveryWithRemoteStoreAndRemoteTranslogFlush

public void testPeerRecoveryWithRemoteStoreAndRemoteTranslogFlush()
                                                           throws Exception

Throws:

Exception

testPeerRecoveryWithLowActivityTimeout

public void testPeerRecoveryWithLowActivityTimeout()
                                            throws Exception

Throws:

Exception

testPeerRecoveryWithRemoteStoreAndRemoteTranslogNoDataRefresh

public void testPeerRecoveryWithRemoteStoreAndRemoteTranslogNoDataRefresh()
                                                                   throws Exception

Throws:

Exception

testPeerRecoveryWithRemoteStoreAndRemoteTranslogRefresh

public void testPeerRecoveryWithRemoteStoreAndRemoteTranslogRefresh()
                                                             throws Exception

Throws:

Exception

testRemoteTranslogCleanup

@AwaitsFix(bugUrl="https://github.com/opensearch-project/OpenSearch/issues/9327")
public void testRemoteTranslogCleanup()
                               throws Exception

Throws:

Exception

testStaleCommitDeletionWithInvokeFlush

public void testStaleCommitDeletionWithInvokeFlush()
                                            throws Exception

Throws:

Exception

testStaleCommitDeletionWithoutInvokeFlush

public void testStaleCommitDeletionWithoutInvokeFlush()
                                               throws Exception

Throws:

Exception

testStaleCommitDeletionWithMinSegmentFiles_3

public void testStaleCommitDeletionWithMinSegmentFiles_3()
                                                  throws Exception

Throws:

Exception

getSegmentBasePath

protected org.opensearch.common.blobstore.BlobPath getSegmentBasePath()

testStaleCommitDeletionWithMinSegmentFiles_Disabled

public void testStaleCommitDeletionWithMinSegmentFiles_Disabled()
                                                         throws Exception

Throws:

Exception

getActualFileCount

protected int getActualFileCount(Path segmentRepoPath,
 String shardPath)
                          throws IOException

Throws:

IOException

testDefaultBufferInterval

public void testDefaultBufferInterval()
                               throws ExecutionException,
InterruptedException

Tests that when the index setting is not passed during index creation, the buffer interval picked up is the cluster default.

Throws:

ExecutionException

InterruptedException

testOverriddenBufferInterval

public void testOverriddenBufferInterval()
                                  throws ExecutionException,
InterruptedException

This tests multiple cases where the index setting is passed during the index creation with multiple combinations with and without cluster default.

Throws:

ExecutionException

InterruptedException

testOverriddenBufferIntervalValidation

public void testOverriddenBufferIntervalValidation()

This tests validation which kicks in during index creation failing creation if the value is less than minimum allowed value.

testClusterBufferIntervalValidation

public void testClusterBufferIntervalValidation()

This tests validation of the cluster setting when being set.

testRequestDurabilityWhenRestrictSettingExplicitFalse

public void testRequestDurabilityWhenRestrictSettingExplicitFalse()
                                                           throws ExecutionException,
InterruptedException

Throws:

ExecutionException

InterruptedException

testAsyncDurabilityWhenRestrictSettingExplicitFalse

public void testAsyncDurabilityWhenRestrictSettingExplicitFalse()
                                                         throws ExecutionException,
InterruptedException

Throws:

ExecutionException

InterruptedException

testRequestDurabilityWhenRestrictSettingImplicitFalse

public void testRequestDurabilityWhenRestrictSettingImplicitFalse()
                                                           throws ExecutionException,
InterruptedException

Throws:

ExecutionException

InterruptedException

testAsyncDurabilityWhenRestrictSettingImplicitFalse

public void testAsyncDurabilityWhenRestrictSettingImplicitFalse()
                                                         throws ExecutionException,
InterruptedException

Throws:

ExecutionException

InterruptedException

testAsyncDurabilityThrowsExceptionWhenRestrictSettingTrue

public void testAsyncDurabilityThrowsExceptionWhenRestrictSettingTrue()
                                                               throws ExecutionException,
InterruptedException

Throws:

ExecutionException

InterruptedException

testRestoreSnapshotToIndexWithSameNameDifferentUUID

public void testRestoreSnapshotToIndexWithSameNameDifferentUUID()
                                                         throws Exception

Throws:

Exception

testNoSearchIdleForAnyReplicaCount

public void testNoSearchIdleForAnyReplicaCount()
                                        throws ExecutionException,
InterruptedException

Throws:

ExecutionException

InterruptedException

testFallbackToNodeToNodeSegmentCopy

public void testFallbackToNodeToNodeSegmentCopy()
                                         throws Exception

Throws:

Exception

delete

protected void delete(Path baseRepoPath,
 String shardPath)
               throws IOException

Throws:

IOException

testNoMultipleWriterDuringPrimaryRelocation

public void testNoMultipleWriterDuringPrimaryRelocation()
                                                 throws ExecutionException,
InterruptedException

Throws:

ExecutionException

InterruptedException

testResumeUploadAfterFailedPrimaryRelocation

public void testResumeUploadAfterFailedPrimaryRelocation()
                                                  throws ExecutionException,
InterruptedException,
IOException

Throws:

ExecutionException

InterruptedException

IOException

testLocalOnlyTranslogCleanupOnNodeRestart

public void testLocalOnlyTranslogCleanupOnNodeRestart()
                                               throws Exception

Throws:

Exception

testFlushOnTooManyRemoteTranslogFiles

public void testFlushOnTooManyRemoteTranslogFiles()
                                           throws Exception

Throws:

Exception

testAsyncTranslogDurabilityRestrictionsThroughIdxTemplates

public void testAsyncTranslogDurabilityRestrictionsThroughIdxTemplates()
                                                                throws Exception

Throws:

Exception

testCloseIndexWithNoOpSyncAndFlushForSyncTranslog

public void testCloseIndexWithNoOpSyncAndFlushForSyncTranslog()
                                                       throws InterruptedException

Throws:

InterruptedException

testCloseIndexWithNoOpSyncAndFlushForAsyncTranslog

public void testCloseIndexWithNoOpSyncAndFlushForAsyncTranslog()
                                                        throws InterruptedException

Throws:

InterruptedException

testSuccessfulShallowV1SnapshotPostIndexClose

public void testSuccessfulShallowV1SnapshotPostIndexClose()
                                                   throws Exception

Throws:

Exception