Class OracleCloudReactiveBucketOperations

java.lang.Object

io.micronaut.objectstorage.oraclecloud.OracleCloudReactiveBucketOperations

All Implemented Interfaces:

ReactiveBucketOperations<com.oracle.bmc.objectstorage.responses.GetBucketResponse>

@EachBean(OracleCloudStorageConfiguration.class)
@Requires(beans=OracleCloudStorageConfiguration.class) @Requires(beans=com.oracle.bmc.objectstorage.ObjectStorageAsync.class)
public class OracleCloudReactiveBucketOperations
extends Object
implements ReactiveBucketOperations<com.oracle.bmc.objectstorage.responses.GetBucketResponse>

Reactive OCI bucket operations.

Since:

3.0.0

Author:

Álvaro Sánchez-Mariscal

Constructor Summary

Constructors

Constructor	Description
OracleCloudReactiveBucketOperations(OracleCloudStorageConfiguration configuration, com.oracle.bmc.objectstorage.ObjectStorageAsync client)

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<com.oracle.bmc.objectstorage.responses.GetBucketResponse>>>	retrieve(@NonNull String name)	Retrieve an existing bucket/container.

Methods inherited from class Object

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

Constructor Details

OracleCloudReactiveBucketOperations

public OracleCloudReactiveBucketOperations(@Parameter
 OracleCloudStorageConfiguration configuration,
 com.oracle.bmc.objectstorage.ObjectStorageAsync client)

Method Details

create

public @NonNull org.reactivestreams.Publisher<Void> create(@NonNull String name)

Description copied from interface: ReactiveBucketOperations

Create a new bucket/container with the given name.

Specified by:

create in interface ReactiveBucketOperations<com.oracle.bmc.objectstorage.responses.GetBucketResponse>

Parameters:

name - The bucket/container name.

Returns:

a completion-only publisher.

retrieve

public @NonNull org.reactivestreams.Publisher<Optional<BucketEntry<com.oracle.bmc.objectstorage.responses.GetBucketResponse>>> retrieve(@NonNull String name)

Description copied from interface: ReactiveBucketOperations

Retrieve an existing bucket/container.

Specified by:

retrieve in interface ReactiveBucketOperations<com.oracle.bmc.objectstorage.responses.GetBucketResponse>

Parameters:

name - The bucket/container name.

Returns:

a publisher that emits the provider-native bucket/container data if it exists.

delete

public @NonNull org.reactivestreams.Publisher<Void> delete(@NonNull String name)

Description copied from interface: ReactiveBucketOperations

Delete a bucket/container with the given name.

Specified by:

delete in interface ReactiveBucketOperations<com.oracle.bmc.objectstorage.responses.GetBucketResponse>

Parameters:

name - The bucket/container name.

Returns:

a completion-only publisher.

exists

public @NonNull org.reactivestreams.Publisher<Boolean> exists(@NonNull String name)

Description copied from interface: ReactiveBucketOperations

Checks whether a bucket/container exists.

Specified by:

exists in interface ReactiveBucketOperations<com.oracle.bmc.objectstorage.responses.GetBucketResponse>

Parameters:

name - The bucket/container name.

Returns:

a publisher that emits true if the bucket/container exists.