Class OpenSearchBlobStoreRepositoryIntegTestCase

java.lang.Object

org.junit.Assert

org.apache.lucene.tests.util.LuceneTestCase

org.opensearch.test.OpenSearchTestCase

org.opensearch.test.OpenSearchIntegTestCase

org.opensearch.repositories.blobstore.OpenSearchBlobStoreRepositoryIntegTestCase

Direct Known Subclasses:

OpenSearchMockAPIBasedRepositoryIntegTestCase

public abstract class OpenSearchBlobStoreRepositoryIntegTestCase
extends OpenSearchIntegTestCase

Integration tests for BlobStoreRepository implementations.

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

Method Summary

Modifier and Type	Method	Description
protected void	addRandomDocuments(String name, int numDocs)
protected static void	assertSuccessfulRestore(org.opensearch.action.admin.cluster.snapshots.restore.RestoreSnapshotRequestBuilder requestBuilder)
protected static void	assertSuccessfulSnapshot(org.opensearch.action.admin.cluster.snapshots.create.CreateSnapshotRequestBuilder requestBuilder)
protected final String	createRepository(String name)
protected final String	createRepository(String name, org.opensearch.common.settings.Settings settings)
static org.opensearch.repositories.RepositoryData	getRepositoryData(org.opensearch.repositories.Repository repository)
protected org.opensearch.common.blobstore.BlobStore	newBlobStore()
static byte[]	randomBytes(int length)
protected static String	randomName()
static byte[]	readBlobFully(org.opensearch.common.blobstore.BlobContainer container, String name, int length)
protected org.opensearch.common.settings.Settings	repositorySettings()
protected abstract String	repositoryType()
void	testContainerCreationAndDeletion()
void	testDeleteBlobs()
void	testIndicesDeletedFromRepository()
void	testList()
void	testMultipleSnapshotAndRollback()
void	testReadNonExistingPath()
void	testReadRange()
void	testSnapshotAndRestore()
void	testWriteRead()
protected static void	writeBlob(org.opensearch.common.blobstore.BlobContainer container, String blobName, org.opensearch.core.common.bytes.BytesArray bytesArray)
static void	writeBlob(org.opensearch.common.blobstore.BlobContainer container, String blobName, org.opensearch.core.common.bytes.BytesArray bytesArray, boolean failIfAlreadyExists)
static byte[]	writeRandomBlob(org.opensearch.common.blobstore.BlobContainer container, String name, int length)

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, indexSettings, internalCluster, isInternalCluster, isMigratingToRemoteStore, isolateClusterManagerDisruption, isSegmentReplicationEnabledForIndex, logClusterState, manageReplicaBalanceSetting, manageReplicaSettingForDefaultReplica, maximumNumberOfReplicas, maximumNumberOfShards, minimumNumberOfReplicas, minimumNumberOfShards, nodeConfigPath, nodePlugins, nodeSettings, 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

Constructor Details

OpenSearchBlobStoreRepositoryIntegTestCase

public OpenSearchBlobStoreRepositoryIntegTestCase()

Method Details

getRepositoryData

public static org.opensearch.repositories.RepositoryData getRepositoryData(org.opensearch.repositories.Repository repository)

repositoryType

protected abstract String repositoryType()

repositorySettings

protected org.opensearch.common.settings.Settings repositorySettings()

createRepository

protected final String createRepository(String name)

createRepository

protected final String createRepository(String name,
 org.opensearch.common.settings.Settings settings)

testReadNonExistingPath

public void testReadNonExistingPath()
                             throws IOException

Throws:

IOException

testWriteRead

public void testWriteRead()
                   throws IOException

Throws:

IOException

testReadRange

public void testReadRange()
                   throws IOException

Throws:

IOException

testList

public void testList()
              throws IOException

Throws:

IOException

testDeleteBlobs

public void testDeleteBlobs()
                     throws IOException

Throws:

IOException

writeBlob

public static void writeBlob(org.opensearch.common.blobstore.BlobContainer container,
 String blobName,
 org.opensearch.core.common.bytes.BytesArray bytesArray,
 boolean failIfAlreadyExists)
                      throws IOException

Throws:

IOException

testContainerCreationAndDeletion

public void testContainerCreationAndDeletion()
                                      throws IOException

Throws:

IOException

writeRandomBlob

public static byte[] writeRandomBlob(org.opensearch.common.blobstore.BlobContainer container,
 String name,
 int length)
                              throws IOException

Throws:

IOException

readBlobFully

public static byte[] readBlobFully(org.opensearch.common.blobstore.BlobContainer container,
 String name,
 int length)
                            throws IOException

Throws:

IOException

randomBytes

public static byte[] randomBytes(int length)

writeBlob

protected static void writeBlob(org.opensearch.common.blobstore.BlobContainer container,
 String blobName,
 org.opensearch.core.common.bytes.BytesArray bytesArray)
                         throws IOException

Throws:

IOException

newBlobStore

protected org.opensearch.common.blobstore.BlobStore newBlobStore()

testSnapshotAndRestore

public void testSnapshotAndRestore()
                            throws Exception

Throws:

Exception

testMultipleSnapshotAndRollback

public void testMultipleSnapshotAndRollback()
                                     throws Exception

Throws:

Exception

testIndicesDeletedFromRepository

public void testIndicesDeletedFromRepository()
                                      throws Exception

Throws:

Exception

addRandomDocuments

protected void addRandomDocuments(String name,
 int numDocs)
                           throws InterruptedException

Throws:

InterruptedException

assertSuccessfulSnapshot

protected static void assertSuccessfulSnapshot(org.opensearch.action.admin.cluster.snapshots.create.CreateSnapshotRequestBuilder requestBuilder)

assertSuccessfulRestore

protected static void assertSuccessfulRestore(org.opensearch.action.admin.cluster.snapshots.restore.RestoreSnapshotRequestBuilder requestBuilder)

randomName

protected static String randomName()