Class MockFsAsyncBlobContainer

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

  • 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
    MockFsAsyncBlobContainer(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)
     
    void
    deleteAsync(org.opensearch.core.action.ActionListener<org.opensearch.common.blobstore.DeleteResult> completionListener)
     
    void
    deleteBlobsAsyncIgnoringIfNotExists(List<String> blobNames, org.opensearch.core.action.ActionListener<Void> completionListener)
     
    void
    readBlobAsync(String blobName, org.opensearch.core.action.ActionListener<org.opensearch.common.blobstore.stream.read.ReadContext> listener)
     
    boolean
    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, readBlobWithMetadata, writeBlob, writeBlobAtomic, writeBlobAtomicWithMetadata, writeBlobWithMetadata

  • Constructor Details

    • MockFsAsyncBlobContainer

      public MockFsAsyncBlobContainer(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
      Throws:
      IOException

    • readBlobAsync

      public void readBlobAsync(String blobName, org.opensearch.core.action.ActionListener<org.opensearch.common.blobstore.stream.read.ReadContext> listener)
      Specified by:
      readBlobAsync in interface org.opensearch.common.blobstore.AsyncMultiStreamBlobContainer

    • remoteIntegrityCheckSupported

      public boolean remoteIntegrityCheckSupported()
      Specified by:
      remoteIntegrityCheckSupported in interface org.opensearch.common.blobstore.AsyncMultiStreamBlobContainer

    • deleteAsync

      public void deleteAsync(org.opensearch.core.action.ActionListener<org.opensearch.common.blobstore.DeleteResult> completionListener)
      Specified by:
      deleteAsync in interface org.opensearch.common.blobstore.AsyncMultiStreamBlobContainer

    • deleteBlobsAsyncIgnoringIfNotExists

      public void deleteBlobsAsyncIgnoringIfNotExists(List<String> blobNames, org.opensearch.core.action.ActionListener<Void> completionListener)
      Specified by:
      deleteBlobsAsyncIgnoringIfNotExists in interface org.opensearch.common.blobstore.AsyncMultiStreamBlobContainer