Interface ReactiveBucketOperations<T>

Type Parameters:
T - The provider-native bucket/container representation type.
All Known Implementing Classes:
AwsS3ReactiveBucketOperations, AzureBlobReactiveBucketOperations, DefaultReactiveBucketOperations, GoogleCloudReactiveBucketOperations, LocalStorageReactiveBucketOperations, OracleCloudReactiveBucketOperations
public interface ReactiveBucketOperations<T>
Reactive companion API for bucket/container lifecycle management.
Since:
3.0.0
Author:
Álvaro Sánchez-Mariscal

  • Method Summary

    Modifier and Type
    Method
    Description
    @NonNull org.reactivestreams.Publisher<Void>
    create(@NonNull String name)
    Create a new bucket/container with the given name.
    @NonNull org.reactivestreams.Publisher<Void>
    delete(@NonNull String name)
    Delete a bucket/container with the given name.
    @NonNull org.reactivestreams.Publisher<Boolean>
    exists(@NonNull String name)
    Checks whether a bucket/container exists.
    @NonNull org.reactivestreams.Publisher<Optional<BucketEntry<T>>>
    retrieve(@NonNull String name)
    Retrieve an existing bucket/container.

  • Method Details

    • create

      @NonNull org.reactivestreams.Publisher<Void> create(@NonNull String name)
      Create a new bucket/container with the given name.
      Parameters:
      name - The bucket/container name.
      Returns:
      a completion-only publisher.

    • retrieve

      @NonNull org.reactivestreams.Publisher<Optional<BucketEntry<T>>> retrieve(@NonNull String name)
      Retrieve an existing bucket/container.
      Parameters:
      name - The bucket/container name.
      Returns:
      a publisher that emits the provider-native bucket/container data if it exists.

    • delete

      @NonNull org.reactivestreams.Publisher<Void> delete(@NonNull String name)
      Delete a bucket/container with the given name.
      Parameters:
      name - The bucket/container name.
      Returns:
      a completion-only publisher.

    • exists

      @NonNull org.reactivestreams.Publisher<Boolean> exists(@NonNull String name)
      Checks whether a bucket/container exists.
      Parameters:
      name - The bucket/container name.
      Returns:
      a publisher that emits true if the bucket/container exists.