Class AzureBlobStorageReactiveOperations

java.lang.Object
io.micronaut.objectstorage.azure.AzureBlobStorageReactiveOperations
All Implemented Interfaces:
ReactiveObjectStorageOperations<com.azure.storage.blob.options.BlobParallelUploadOptions, com.azure.storage.blob.models.BlockBlobItem, com.azure.core.http.rest.Response<Void>>
@EachBean(com.azure.storage.blob.BlobContainerAsyncClient.class) @Requires(beans=com.azure.storage.blob.BlobContainerAsyncClient.class) @Requires(condition=AzureBlobStorageEnabledCondition.class) public final class AzureBlobStorageReactiveOperations extends Object implements ReactiveObjectStorageOperations<com.azure.storage.blob.options.BlobParallelUploadOptions, com.azure.storage.blob.models.BlockBlobItem, com.azure.core.http.rest.Response<Void>>
Reactive Azure Blob Storage operations backed by Azure async blob clients.
Since:
3.0.0
Author:
Álvaro Sánchez-Mariscal

  • Constructor Summary

    Constructors
    Constructor
    Description
    AzureBlobStorageReactiveOperations(com.azure.storage.blob.BlobContainerAsyncClient blobContainerAsyncClient)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    @NonNull org.reactivestreams.Publisher<Void>
    copy(@NonNull String sourceKey, @NonNull String destinationKey)
    Copies an object stored at sourceKey to destinationKey, within the same object storage (bucket/container).
    @NonNull org.reactivestreams.Publisher<com.azure.core.http.rest.Response<Void>>
    delete(@NonNull String key)
    Deletes an object from the object storage.
    @NonNull org.reactivestreams.Publisher<Boolean>
    exists(@NonNull String key)
    Checks whether an entry with the given key exists in the object storage.
    @NonNull org.reactivestreams.Publisher<Set<String>>
    listObjects()
    Lists the objects that exist in the object storage.
    @NonNull org.reactivestreams.Publisher<ListObjectsResponse>
    listObjects(@NonNull ListObjectsRequest request)
    Lists a page of objects that exist in the object storage.
    <E extends ObjectStorageEntry<?>>
    @NonNull org.reactivestreams.Publisher<Optional<E>>
    retrieve(@NonNull String key)
    Gets the object from object storage.
    @NonNull org.reactivestreams.Publisher<UploadResponse<com.azure.storage.blob.models.BlockBlobItem>>
    upload(@NonNull UploadRequest request)
    Uploads an object to the object storage.
    @NonNull org.reactivestreams.Publisher<UploadResponse<com.azure.storage.blob.models.BlockBlobItem>>
    upload(@NonNull UploadRequest request, @NonNull Consumer<com.azure.storage.blob.options.BlobParallelUploadOptions> requestConsumer)
    Uploads an object to the object storage.

    Methods inherited from class Object

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

  • Constructor Details

    • AzureBlobStorageReactiveOperations

      public AzureBlobStorageReactiveOperations(@Parameter com.azure.storage.blob.BlobContainerAsyncClient blobContainerAsyncClient)

  • Method Details

    • upload

      public @NonNull org.reactivestreams.Publisher<UploadResponse<com.azure.storage.blob.models.BlockBlobItem>> upload(@NonNull UploadRequest request)
      Description copied from interface: ReactiveObjectStorageOperations
      Uploads an object to the object storage. If there is an existing entry, it will be updated.
      Specified by:
      upload in interface ReactiveObjectStorageOperations<com.azure.storage.blob.options.BlobParallelUploadOptions, com.azure.storage.blob.models.BlockBlobItem, com.azure.core.http.rest.Response<Void>>
      Parameters:
      request - the upload request
      Returns:
      a publisher that emits the upload response

    • upload

      public @NonNull org.reactivestreams.Publisher<UploadResponse<com.azure.storage.blob.models.BlockBlobItem>> upload(@NonNull UploadRequest request, @NonNull Consumer<com.azure.storage.blob.options.BlobParallelUploadOptions> requestConsumer)
      Description copied from interface: ReactiveObjectStorageOperations
      Uploads an object to the object storage. If there is an existing entry, it will be updated.
      Specified by:
      upload in interface ReactiveObjectStorageOperations<com.azure.storage.blob.options.BlobParallelUploadOptions, com.azure.storage.blob.models.BlockBlobItem, com.azure.core.http.rest.Response<Void>>
      Parameters:
      request - the upload request
      requestConsumer - upload request builder consumer
      Returns:
      a publisher that emits the upload response

    • retrieve

      public <E extends ObjectStorageEntry<?>> @NonNull org.reactivestreams.Publisher<Optional<E>> retrieve(@NonNull String key)
      Description copied from interface: ReactiveObjectStorageOperations
      Gets the object from object storage.
      Specified by:
      retrieve in interface ReactiveObjectStorageOperations<com.azure.storage.blob.options.BlobParallelUploadOptions, com.azure.storage.blob.models.BlockBlobItem, com.azure.core.http.rest.Response<Void>>
      Type Parameters:
      E - an instance of ObjectStorageEntry
      Parameters:
      key - the object path in the format /foo/bar/file
      Returns:
      a publisher that emits an optional object storage entry

    • delete

      public @NonNull org.reactivestreams.Publisher<com.azure.core.http.rest.Response<Void>> delete(@NonNull String key)
      Description copied from interface: ReactiveObjectStorageOperations
      Deletes an object from the object storage.
      Specified by:
      delete in interface ReactiveObjectStorageOperations<com.azure.storage.blob.options.BlobParallelUploadOptions, com.azure.storage.blob.models.BlockBlobItem, com.azure.core.http.rest.Response<Void>>
      Parameters:
      key - object path in the format /foo/bar/file
      Returns:
      a publisher that emits the cloud vendor-specific delete response

    • exists

      public @NonNull org.reactivestreams.Publisher<Boolean> exists(@NonNull String key)
      Description copied from interface: ReactiveObjectStorageOperations
      Checks whether an entry with the given key exists in the object storage.
      Specified by:
      exists in interface ReactiveObjectStorageOperations<com.azure.storage.blob.options.BlobParallelUploadOptions, com.azure.storage.blob.models.BlockBlobItem, com.azure.core.http.rest.Response<Void>>
      Parameters:
      key - object path in the format /foo/bar/file
      Returns:
      a publisher that emits true if the entry exists, false otherwise

    • listObjects

      public @NonNull org.reactivestreams.Publisher<Set<String>> listObjects()
      Description copied from interface: ReactiveObjectStorageOperations
      Lists the objects that exist in the object storage.
      Specified by:
      listObjects in interface ReactiveObjectStorageOperations<com.azure.storage.blob.options.BlobParallelUploadOptions, com.azure.storage.blob.models.BlockBlobItem, com.azure.core.http.rest.Response<Void>>
      Returns:
      a publisher that emits the full set of keys

    • listObjects

      public @NonNull org.reactivestreams.Publisher<ListObjectsResponse> listObjects(@NonNull ListObjectsRequest request)
      Description copied from interface: ReactiveObjectStorageOperations
      Lists a page of objects that exist in the object storage.
      Specified by:
      listObjects in interface ReactiveObjectStorageOperations<com.azure.storage.blob.options.BlobParallelUploadOptions, com.azure.storage.blob.models.BlockBlobItem, com.azure.core.http.rest.Response<Void>>
      Parameters:
      request - the paginated listing request
      Returns:
      a publisher that emits the current page of object keys

    • copy

      public @NonNull org.reactivestreams.Publisher<Void> copy(@NonNull String sourceKey, @NonNull String destinationKey)
      Description copied from interface: ReactiveObjectStorageOperations
      Copies an object stored at sourceKey to destinationKey, within the same object storage (bucket/container). If the destination exists, it will be overwritten.
      Specified by:
      copy in interface ReactiveObjectStorageOperations<com.azure.storage.blob.options.BlobParallelUploadOptions, com.azure.storage.blob.models.BlockBlobItem, com.azure.core.http.rest.Response<Void>>
      Parameters:
      sourceKey - the key of the source object
      destinationKey - the key of the destination object
      Returns:
      a completion-only publisher