Class MockRepository
java.lang.Object
org.opensearch.common.component.AbstractLifecycleComponent
org.opensearch.repositories.blobstore.BlobStoreRepository
org.opensearch.repositories.fs.FsRepository
org.opensearch.snapshots.mockstore.MockRepository
- All Implemented Interfaces:
java.io.Closeable,java.lang.AutoCloseable,org.opensearch.common.component.LifecycleComponent,org.opensearch.common.lease.Releasable,org.opensearch.repositories.Repository
public class MockRepository
extends org.opensearch.repositories.fs.FsRepository
-
Nested Class Summary
Nested Classes Modifier and Type Class Description classMockRepository.MockBlobStorestatic classMockRepository.Plugin -
Field Summary
Fields inherited from class org.opensearch.repositories.fs.FsRepository
CHUNK_SIZE_SETTING, COMPRESS_SETTING, LOCATION_SETTING, REPOSITORIES_CHUNK_SIZE_SETTING, REPOSITORIES_COMPRESS_SETTING, REPOSITORIES_LOCATION_SETTING, TYPEFields inherited from class org.opensearch.repositories.blobstore.BlobStoreRepository
ALLOW_CONCURRENT_MODIFICATION, BUFFER_SIZE_SETTING, bufferSize, CACHE_REPOSITORY_DATA, GLOBAL_METADATA_FORMAT, INDEX_FILE_PREFIX, INDEX_LATEST_BLOB, INDEX_METADATA_FORMAT, INDEX_SHARD_SNAPSHOT_FORMAT, INDEX_SHARD_SNAPSHOTS_FORMAT, metadata, METADATA_NAME_FORMAT, METADATA_PREFIX, SNAPSHOT_FORMAT, SNAPSHOT_NAME_FORMAT, SNAPSHOT_PREFIX, SUPPORT_URL_REPO, supportURLRepo, threadPool -
Constructor Summary
Constructors Constructor Description MockRepository(org.opensearch.cluster.metadata.RepositoryMetadata metadata, org.opensearch.env.Environment environment, org.opensearch.common.xcontent.NamedXContentRegistry namedXContentRegistry, org.opensearch.cluster.service.ClusterService clusterService, org.opensearch.indices.recovery.RecoverySettings recoverySettings) -
Method Summary
Modifier and Type Method Description booleanblocked()voidblockOnDataFiles(boolean blocked)protected org.opensearch.common.blobstore.BlobStorecreateBlobStore()protected voiddoStop()longgetFailureCount()org.opensearch.cluster.metadata.RepositoryMetadatagetMetadata()voidsetBlockAndFailOnWriteIndexFile()voidsetBlockAndFailOnWriteSnapFiles(boolean blocked)voidsetBlockOnAnyFiles(boolean blocked)voidsetBlockOnDeleteIndexFile()voidsetBlockOnReadIndexMeta()voidsetBlockOnWriteIndexFile()voidsetBlockOnWriteShardLevelMeta()voidsetFailOnIndexLatest(boolean failOnIndexLatest)voidsetFailReadsAfterUnblock(boolean failReadsAfterUnblock)voidsetThrowExceptionWhileDelete(boolean throwError)voidunblock()Methods inherited from class org.opensearch.repositories.blobstore.BlobStoreRepository
assertSnapshotOrGenericThread, blobContainer, blobStore, cleanup, cloneShardSnapshot, deleteSnapshots, doClose, doStart, endVerification, executeConsistentStateUpdate, finalizeSnapshot, getBlobStore, getRepositoryData, getRestoreThrottleTimeInNanos, getShardSnapshotStatus, getSnapshotGlobalMetadata, getSnapshotIndexMetaData, getSnapshotInfo, getSnapshotThrottleTimeInNanos, initializeSnapshot, isCompress, isReadOnly, loadShardSnapshot, maybeRateLimitRestores, maybeRateLimitSnapshots, restoreShard, shardContainer, snapshotShard, startVerification, stats, threadPool, toString, updateState, verify, writeIndexGenMethods inherited from class org.opensearch.common.component.AbstractLifecycleComponent
addLifecycleListener, close, lifecycleState, removeLifecycleListener, start, stopMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Constructor Details
-
MockRepository
public MockRepository(org.opensearch.cluster.metadata.RepositoryMetadata metadata, org.opensearch.env.Environment environment, org.opensearch.common.xcontent.NamedXContentRegistry namedXContentRegistry, org.opensearch.cluster.service.ClusterService clusterService, org.opensearch.indices.recovery.RecoverySettings recoverySettings)
-
-
Method Details
-
getFailureCount
public long getFailureCount() -
getMetadata
public org.opensearch.cluster.metadata.RepositoryMetadata getMetadata()- Specified by:
getMetadatain interfaceorg.opensearch.repositories.Repository- Overrides:
getMetadatain classorg.opensearch.repositories.blobstore.BlobStoreRepository
-
doStop
protected void doStop()- Overrides:
doStopin classorg.opensearch.repositories.blobstore.BlobStoreRepository
-
createBlobStore
protected org.opensearch.common.blobstore.BlobStore createBlobStore() throws java.lang.Exception- Overrides:
createBlobStorein classorg.opensearch.repositories.fs.FsRepository- Throws:
java.lang.Exception
-
unblock
public void unblock() -
blockOnDataFiles
public void blockOnDataFiles(boolean blocked) -
setBlockOnAnyFiles
public void setBlockOnAnyFiles(boolean blocked) -
setBlockAndFailOnWriteSnapFiles
public void setBlockAndFailOnWriteSnapFiles(boolean blocked) -
setBlockAndFailOnWriteIndexFile
public void setBlockAndFailOnWriteIndexFile() -
setBlockOnWriteIndexFile
public void setBlockOnWriteIndexFile() -
setBlockOnDeleteIndexFile
public void setBlockOnDeleteIndexFile() -
setBlockOnWriteShardLevelMeta
public void setBlockOnWriteShardLevelMeta() -
setBlockOnReadIndexMeta
public void setBlockOnReadIndexMeta() -
setFailReadsAfterUnblock
public void setFailReadsAfterUnblock(boolean failReadsAfterUnblock) -
setThrowExceptionWhileDelete
public void setThrowExceptionWhileDelete(boolean throwError) -
blocked
public boolean blocked() -
setFailOnIndexLatest
public void setFailOnIndexLatest(boolean failOnIndexLatest)
-