Class MockFsMetadataSupportedBlobContainer

java.lang.Object
org.opensearch.common.blobstore.support.AbstractBlobContainer
org.opensearch.common.blobstore.fs.FsBlobContainer
org.opensearch.remotestore.multipart.mocks.MockFsAsyncBlobContainer
org.opensearch.remotestore.mocks.MockFsMetadataSupportedBlobContainer
All Implemented Interfaces:
org.opensearch.common.blobstore.AsyncMultiStreamBlobContainer, org.opensearch.common.blobstore.BlobContainer
public class MockFsMetadataSupportedBlobContainer extends MockFsAsyncBlobContainer

  • Nested Class Summary

    Nested classes/interfaces inherited from interface org.opensearch.common.blobstore.BlobContainer

    org.opensearch.common.blobstore.BlobContainer.BlobNameSortOrder

  • Field Summary

    Fields inherited from class org.opensearch.common.blobstore.fs.FsBlobContainer

    blobStore, path

  • Constructor Summary

    Constructors
    Constructor
    Description
    MockFsMetadataSupportedBlobContainer(org.opensearch.common.blobstore.fs.FsBlobStore blobStore, org.opensearch.common.blobstore.BlobPath blobPath, Path path, boolean triggerDataIntegrityFailure)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    asyncBlobUpload(org.opensearch.common.blobstore.stream.write.WriteContext writeContext, org.opensearch.core.action.ActionListener<Void> completionListener)
     
    static String
    convertToBase64(InputStream inputStream)
     
    org.opensearch.common.blobstore.InputStreamWithMetadata
    readBlobWithMetadata(String blobName)
     

    Methods inherited from class org.opensearch.remotestore.multipart.mocks.MockFsAsyncBlobContainer

    deleteAsync, deleteBlobsAsyncIgnoringIfNotExists, readBlobAsync, remoteIntegrityCheckSupported

    Methods inherited from class org.opensearch.common.blobstore.fs.FsBlobContainer

    blobExists, children, delete, deleteBlobsIgnoringIfNotExists, isTempBlobName, listBlobs, listBlobsByPrefix, moveBlobAtomic, readBlob, readBlob, readBlobPreferredLength, tempBlobName, writeBlob, writeBlobAtomic

    Methods inherited from class org.opensearch.common.blobstore.support.AbstractBlobContainer

    path

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface org.opensearch.common.blobstore.BlobContainer

    blobExists, children, delete, deleteBlobsIgnoringIfNotExists, listBlobs, listBlobsByPrefix, listBlobsByPrefixInSortedOrder, listBlobsByPrefixInSortedOrder, path, readBlob, readBlob, readBlobPreferredLength, writeBlob, writeBlobAtomic, writeBlobAtomicWithMetadata, writeBlobWithMetadata

  • Constructor Details

    • MockFsMetadataSupportedBlobContainer

      public MockFsMetadataSupportedBlobContainer(org.opensearch.common.blobstore.fs.FsBlobStore blobStore, org.opensearch.common.blobstore.BlobPath blobPath, Path path, boolean triggerDataIntegrityFailure)

  • Method Details

    • asyncBlobUpload

      public void asyncBlobUpload(org.opensearch.common.blobstore.stream.write.WriteContext writeContext, org.opensearch.core.action.ActionListener<Void> completionListener) throws IOException
      Specified by:
      asyncBlobUpload in interface org.opensearch.common.blobstore.AsyncMultiStreamBlobContainer
      Overrides:
      asyncBlobUpload in class MockFsAsyncBlobContainer
      Throws:
      IOException

    • convertToBase64

      public static String convertToBase64(InputStream inputStream) throws IOException
      Throws:
      IOException

    • readBlobWithMetadata

      public org.opensearch.common.blobstore.InputStreamWithMetadata readBlobWithMetadata(String blobName) throws IOException
      Throws:
      IOException