Package com.couchbase.client.java

Class ReactiveBucket

java.lang.Object

com.couchbase.client.java.ReactiveBucket

public class ReactiveBucket
extends Object

Provides access to a Couchbase bucket in a reactive fashion.

Method Summary

Modifier and Type	Method	Description
AsyncBucket	async()	Provides access to the underlying AsyncBucket.
Mono<ReactiveCollection>	collection(String name)	Opens the collection with the given name for this ReactiveBucket.
ReactiveCollectionManager	collections()
Core	core()	Provides access to the underlying Core.
Mono<ReactiveCollection>	defaultCollection()	Opens the default collection for this ReactiveBucket.
Mono<ReactiveScope>	defaultScope()	Opens the default ReactiveScope.
ClusterEnvironment	environment()	Returns the attached ClusterEnvironment.
String	name()	Returns the name of the ReactiveBucket.
Mono<PingResult>	ping()	Performs a diagnostic active "ping" call on all services.
Mono<PingResult>	ping(PingOptions options)	Performs a diagnostic active "ping" call with custom options, on all services.
Mono<ReactiveScope>	scope(String name)	Opens the ReactiveScope with the given name.
Mono<ReactiveViewResult>	viewQuery(String designDoc, String viewName)
Mono<ReactiveViewResult>	viewQuery(String designDoc, String viewName, ViewOptions options)

Methods inherited from class java.lang.Object

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

Method Detail

async

public AsyncBucket async()

Provides access to the underlying AsyncBucket.

name

public String name()

Returns the name of the ReactiveBucket.

core

@Volatile
public Core core()

Provides access to the underlying Core.

This is advanced API, use with care!

collections

@Volatile
public ReactiveCollectionManager collections()

environment

public ClusterEnvironment environment()

Returns the attached ClusterEnvironment.

scope

@Volatile
public Mono<ReactiveScope> scope(String name)

Opens the ReactiveScope with the given name.

Parameters:

name - the name of the scope.

Returns:

the ReactiveScope once opened.

defaultScope

@Volatile
public Mono<ReactiveScope> defaultScope()

Opens the default ReactiveScope.

Returns:

the ReactiveScope once opened.

defaultCollection

public Mono<ReactiveCollection> defaultCollection()

Opens the default collection for this ReactiveBucket.

Returns:

the ReactiveCollection once opened.

collection

@Volatile
public Mono<ReactiveCollection> collection(String name)

Opens the collection with the given name for this ReactiveBucket.

Returns:

the ReactiveCollection once opened.

viewQuery

public Mono<ReactiveViewResult> viewQuery(String designDoc,
                                          String viewName)

viewQuery

public Mono<ReactiveViewResult> viewQuery(String designDoc,
                                          String viewName,
                                          ViewOptions options)

ping

@Volatile
public Mono<PingResult> ping(PingOptions options)

Performs a diagnostic active "ping" call with custom options, on all services. Note that since each service has different timeouts, you need to provide a timeout that suits your needs (how long each individual service ping should take max before it times out).

Parameters:

options - options controlling the final ping result

Returns:

a ping report once created.

ping

@Volatile
public Mono<PingResult> ping()

Performs a diagnostic active "ping" call on all services. Note that since each service has different timeouts, you need to provide a timeout that suits your needs (how long each individual service ping should take max before it times out).

Returns:

a ping report once created.