Package com.couchbase.client.java.manager.collection

Class ReactiveCollectionManager

java.lang.Object

com.couchbase.client.java.manager.collection.ReactiveCollectionManager

@Volatile
public class ReactiveCollectionManager
extends Object

The ReactiveCollectionManager provides APIs to manage collections and scopes within a bucket.

Constructor Summary

Constructors

Constructor	Description
ReactiveCollectionManager(ReactorOps reactor, AsyncCollectionManager async)	Creates a new ReactiveCollectionManager.

Method Summary

Modifier and Type	Method	Description
Mono<Void>	createCollection(CollectionSpec collectionSpec)	Deprecated. This method cannot be used to set the collection's "history" property.
Mono<Void>	createCollection(CollectionSpec collectionSpec, CreateCollectionOptions options)	Deprecated. This method cannot be used to set the collection's "history" property.
Mono<Void>	createCollection(String scopeName, String collectionName, CreateCollectionSettings settings)	Creates a collection if it does not already exist with custom options.
Mono<Void>	createCollection(String scopeName, String collectionName, CreateCollectionSettings settings, CreateCollectionOptions options)	Creates a collection if it does not already exist with custom options.
Mono<Void>	createScope(String scopeName)	Creates a scope if it does not already exist.
Mono<Void>	createScope(String scopeName, CreateScopeOptions options)	Creates a scope if it does not already exist with custom options.
Mono<Void>	dropCollection(CollectionSpec collectionSpec)	Deprecated. Please use dropCollection(String, String) instead.
Mono<Void>	dropCollection(CollectionSpec collectionSpec, DropCollectionOptions options)	Deprecated. Please use dropCollection(String, String, DropCollectionOptions) instead.
Mono<Void>	dropCollection(String scopeName, String collectionName)	Drops a collection if it exists.
Mono<Void>	dropCollection(String scopeName, String collectionName, DropCollectionOptions options)	Drops a collection if it exists with custom options.
Mono<Void>	dropScope(String scopeName)	Drops a scope if it exists.
Mono<Void>	dropScope(String scopeName, DropScopeOptions options)	Drops a scope if it exists with custom options.
Flux<ScopeSpec>	getAllScopes()	Returns all scopes in this bucket.
Flux<ScopeSpec>	getAllScopes(GetAllScopesOptions options)	Returns all scopes in this bucket with custom options.
Mono<ScopeSpec>	getScope(String scopeName)	Deprecated. use getAllScopes() instead.
Mono<ScopeSpec>	getScope(String scopeName, GetScopeOptions options)	Deprecated. use getAllScopes(GetAllScopesOptions) instead.
Mono<Void>	updateCollection(String scopeName, String collectionName, UpdateCollectionSettings settings)	Updates a collection with custom options.
Mono<Void>	updateCollection(String scopeName, String collectionName, UpdateCollectionSettings settings, UpdateCollectionOptions options)	Updates a collection with custom options.

Methods inherited from class java.lang.Object

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

Constructor Details

ReactiveCollectionManager

@Internal
public ReactiveCollectionManager(ReactorOps reactor,
 AsyncCollectionManager async)

Creates a new ReactiveCollectionManager.

This API is not intended to be called by the user directly, use ReactiveBucket.collections() instead.

Parameters:

async - the underlying async collection manager.

Method Details

createCollection

@Deprecated
public Mono<Void> createCollection(CollectionSpec collectionSpec)

Deprecated.

This method cannot be used to set the collection's "history" property. Please use createCollection(String, String, CreateCollectionSettings) instead.

Creates a collection if it does not already exist.

Note that a scope needs to be created first (via createScope(String)) if it doesn't exist already.

Parameters:

collectionSpec - the collection spec that contains the properties of the collection.

Returns:

a Mono completing when the operation is applied or failed with an error.

Throws:

CollectionExistsException - (async) if the collection already exists

ScopeNotFoundException - (async) if the specified scope does not exist.

CouchbaseException - (async) if any other generic unhandled/unexpected errors.

createCollection

@Deprecated
public Mono<Void> createCollection(CollectionSpec collectionSpec,
 CreateCollectionOptions options)

Deprecated.

This method cannot be used to set the collection's "history" property. Please use createCollection(String, String, CreateCollectionSettings, CreateCollectionOptions) instead.

Creates a collection if it does not already exist with custom options.

Note that a scope needs to be created first (via createScope(String)) if it doesn't exist already.

Parameters:

collectionSpec - the collection spec that contains the properties of the collection.

options - the custom options to apply.

Returns:

a Mono completing when the operation is applied or failed with an error.

Throws:

CollectionExistsException - (async) if the collection already exists

ScopeNotFoundException - (async) if the specified scope does not exist.

CouchbaseException - (async) if any other generic unhandled/unexpected errors.

createCollection

@Volatile
public Mono<Void> createCollection(String scopeName,
 String collectionName,
 CreateCollectionSettings settings)

Creates a collection if it does not already exist with custom options.

Note that a scope needs to be created first (via createScope(String)) if it doesn't exist already.

Parameters:

scopeName - name of scope to create collection in

collectionName - name of collection to create

settings - the collection settings

Returns:

a Mono completing when the operation is applied or failed with an error.

Throws:

CollectionExistsException - (async) if the collection already exists

ScopeNotFoundException - (async) if the specified scope does not exist.

CouchbaseException - (async) if any other generic unhandled/unexpected errors.

createCollection

@Volatile
public Mono<Void> createCollection(String scopeName,
 String collectionName,
 CreateCollectionSettings settings,
 CreateCollectionOptions options)

Creates a collection if it does not already exist with custom options.

Note that a scope needs to be created first (via createScope(String)) if it doesn't exist already.

Parameters:

scopeName - name of scope to create collection in

collectionName - name of collection to create

settings - the collection settings

options - the custom options to apply.

Returns:

a Mono completing when the operation is applied or failed with an error.

Throws:

CollectionExistsException - (async) if the collection already exists.

ScopeNotFoundException - (async) if the specified scope does not exist.

CouchbaseException - (async) if any other generic unhandled/unexpected errors.

createScope

public Mono<Void> createScope(String scopeName)

Creates a scope if it does not already exist.

Parameters:

scopeName - the name of the scope to create.

Returns:

a Mono completing when the operation is applied or failed with an error.

Throws:

ScopeExistsException - (async) if the scope already exists.

CouchbaseException - (async) if any other generic unhandled/unexpected errors.

createScope

public Mono<Void> createScope(String scopeName,
 CreateScopeOptions options)

Creates a scope if it does not already exist with custom options.

Parameters:

scopeName - the name of the scope to create.

options - the custom options to apply.

Returns:

a Mono completing when the operation is applied or failed with an error.

Throws:

ScopeExistsException - (async) if the scope already exists.

CouchbaseException - (async) if any other generic unhandled/unexpected errors.

updateCollection

@Volatile
public Mono<Void> updateCollection(String scopeName,
 String collectionName,
 UpdateCollectionSettings settings)

Updates a collection with custom options.

Parameters:

scopeName - name of scope to update collection in

collectionName - name of collection to update

settings - the collection settings

Returns:

a CompletableFuture completing when the operation is applied or failed with an error.

Throws:

CollectionNotFoundException - (async) if the specified collection does not exist.

ScopeNotFoundException - (async) if the specified scope does not exist.

CouchbaseException - (async) if any other generic unhandled/unexpected errors.

updateCollection

@Volatile
public Mono<Void> updateCollection(String scopeName,
 String collectionName,
 UpdateCollectionSettings settings,
 UpdateCollectionOptions options)

Updates a collection with custom options.

Parameters:

scopeName - name of scope to update collection in

collectionName - name of collection to update

settings - the collection settings

options - the custom options to apply.

Returns:

a CompletableFuture completing when the operation is applied or failed with an error.

Throws:

CollectionNotFoundException - (async) if the specified collection does not exist.

ScopeNotFoundException - (async) if the specified scope does not exist.

CouchbaseException - (async) if any other generic unhandled/unexpected errors.

dropCollection

@Deprecated
public Mono<Void> dropCollection(CollectionSpec collectionSpec)

Deprecated.

Please use dropCollection(String, String) instead.

Drops a collection if it exists.

Parameters:

collectionSpec - the collection spec that contains the properties of the collection.

Returns:

a Mono completing when the operation is applied or failed with an error.

Throws:

CollectionNotFoundException - (async) if the collection did not exist.

ScopeNotFoundException - (async) if the specified scope does not exist.

CouchbaseException - (async) if any other generic unhandled/unexpected errors.

dropCollection

@Deprecated
public Mono<Void> dropCollection(CollectionSpec collectionSpec,
 DropCollectionOptions options)

Deprecated.

Please use dropCollection(String, String, DropCollectionOptions) instead.

Drops a collection if it exists with custom options.

Parameters:

collectionSpec - the collection spec that contains the properties of the collection.

options - the custom options to apply.

Returns:

a Mono completing when the operation is applied or failed with an error.

Throws:

CollectionNotFoundException - (async) if the collection did not exist.

ScopeNotFoundException - (async) if the specified scope does not exist.

CouchbaseException - (async) if any other generic unhandled/unexpected errors.

dropCollection

@Volatile
public Mono<Void> dropCollection(String scopeName,
 String collectionName)

Drops a collection if it exists.

Parameters:

scopeName - name of scope to drop collection from

collectionName - name of collection to drop

Returns:

a Mono completing when the operation is applied or failed with an error.

Throws:

CollectionNotFoundException - (async) if the collection did not exist.

ScopeNotFoundException - (async) if the specified scope does not exist.

CouchbaseException - (async) if any other generic unhandled/unexpected errors.

dropCollection

@Volatile
public Mono<Void> dropCollection(String scopeName,
 String collectionName,
 DropCollectionOptions options)

Drops a collection if it exists with custom options.

Parameters:

scopeName - name of scope to drop collection from

collectionName - name of collection to drop

options - the custom options to apply.

Returns:

a Mono completing when the operation is applied or failed with an error.

Throws:

CollectionNotFoundException - (async) if the collection did not exist.

ScopeNotFoundException - (async) if the specified scope does not exist.

CouchbaseException - (async) if any other generic unhandled/unexpected errors.

dropScope

public Mono<Void> dropScope(String scopeName)

Drops a scope if it exists.

Parameters:

scopeName - the name of the scope to drop.

Returns:

a Mono completing when the operation is applied or failed with an error.

Throws:

ScopeNotFoundException - (async) if the scope did not exist.

CouchbaseException - (async) if any other generic unhandled/unexpected errors.

dropScope

public Mono<Void> dropScope(String scopeName,
 DropScopeOptions options)

Drops a scope if it exists with custom options.

Parameters:

scopeName - the name of the scope to drop.

options - the custom options to apply.

Returns:

a Mono completing when the operation is applied or failed with an error.

Throws:

ScopeNotFoundException - (async) if the scope did not exist.

CouchbaseException - (async) if any other generic unhandled/unexpected errors.

getScope

@Deprecated
public Mono<ScopeSpec> getScope(String scopeName)

Deprecated.

use getAllScopes() instead.

Returns the scope if it exists.

Parameters:

scopeName - the name of the scope.

Returns:

a Mono containing information about the scope.

Throws:

ScopeNotFoundException - (async) if scope does not exist.

CouchbaseException - (async) if any other generic unhandled/unexpected errors.

getScope

@Deprecated
public Mono<ScopeSpec> getScope(String scopeName,
 GetScopeOptions options)

Deprecated.

use getAllScopes(GetAllScopesOptions) instead.

Returns the scope if it exists with custom options.

Parameters:

scopeName - the name of the scope.

options - the custom options to apply.

Returns:

a Mono containing information about the scope.

Throws:

ScopeNotFoundException - (async) if scope does not exist.

CouchbaseException - (async) if any other generic unhandled/unexpected errors.

getAllScopes

public Flux<ScopeSpec> getAllScopes()

Returns all scopes in this bucket.

Returns:

a Flux with a (potentially empty) list of scopes in the bucket.

Throws:

CouchbaseException - (async) if any other generic unhandled/unexpected errors.

getAllScopes

public Flux<ScopeSpec> getAllScopes(GetAllScopesOptions options)

Returns all scopes in this bucket with custom options.

Parameters:

options - the custom options to apply.

Returns:

a Flux with a (potentially empty) list of scopes in the bucket.

Throws:

CouchbaseException - (async) if any other generic unhandled/unexpected errors.