Class DefaultReactiveBucketMetadataOperations<T>

java.lang.Object

io.micronaut.objectstorage.internal.DefaultReactiveBucketMetadataOperations<T>

Type Parameters:

T - The provider-native metadata representation type.

All Implemented Interfaces:

ReactiveBucketMetadataOperations<T>

Direct Known Subclasses:

LocalStorageReactiveBucketMetadataOperations

@Internal
public class DefaultReactiveBucketMetadataOperations<T>
extends Object
implements ReactiveBucketMetadataOperations<T>

Executor-backed reactive adapter for the blocking bucket metadata contract.

Since:

3.0.0

Author:

Álvaro Sánchez-Mariscal

Constructor Summary

Constructors

Constructor	Description
DefaultReactiveBucketMetadataOperations(BucketMetadataOperations<T> delegate, ExecutorService blockingExecutor)

Method Summary

Modifier and Type	Method	Description
@NonNull org.reactivestreams.Publisher<Void>	delete(@NonNull String name)	Deletes the metadata snapshot for a bucket or container.
@NonNull org.reactivestreams.Publisher<Boolean>	exists(@NonNull String name)	Checks whether a metadata snapshot exists for a bucket or container.
@NonNull org.reactivestreams.Publisher<Optional<BucketMetadataEntry<T>>>	retrieve(@NonNull String name)	Retrieves the stored metadata snapshot for a bucket or container.
@NonNull org.reactivestreams.Publisher<Void>	save(@NonNull BucketMetadataWrite write)	Saves a metadata snapshot for a bucket or container.

Methods inherited from class Object

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

Constructor Details

DefaultReactiveBucketMetadataOperations

public DefaultReactiveBucketMetadataOperations(BucketMetadataOperations<T> delegate,
 ExecutorService blockingExecutor)

Method Details

retrieve

public @NonNull org.reactivestreams.Publisher<Optional<BucketMetadataEntry<T>>> retrieve(@NonNull String name)

Description copied from interface: ReactiveBucketMetadataOperations

Retrieves the stored metadata snapshot for a bucket or container.

Specified by:

retrieve in interface ReactiveBucketMetadataOperations<T>

Parameters:

name - The bucket or container name.

Returns:

A publisher that emits the metadata entry if one exists.

save

public @NonNull org.reactivestreams.Publisher<Void> save(@NonNull BucketMetadataWrite write)

Description copied from interface: ReactiveBucketMetadataOperations

Saves a metadata snapshot for a bucket or container.

Specified by:

save in interface ReactiveBucketMetadataOperations<T>

Parameters:

write - The metadata snapshot to persist.

Returns:

A completion-only publisher.

delete

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

Description copied from interface: ReactiveBucketMetadataOperations

Deletes the metadata snapshot for a bucket or container.

Specified by:

delete in interface ReactiveBucketMetadataOperations<T>

Parameters:

name - The bucket or container name.

Returns:

A completion-only publisher.

exists

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

Description copied from interface: ReactiveBucketMetadataOperations

Checks whether a metadata snapshot exists for a bucket or container.

Specified by:

exists in interface ReactiveBucketMetadataOperations<T>

Parameters:

name - The bucket or container name.

Returns:

A publisher that emits true if metadata exists for the bucket or container.