Modifier and Type | Class and Description |
---|---|
class |
CouchbaseBucket |
Modifier and Type | Method and Description |
---|---|
Bucket |
CouchbaseCluster.openBucket() |
Bucket |
Cluster.openBucket()
Opens the default bucket with an empty password with the default connect timeout.
|
Bucket |
CouchbaseCluster.openBucket(long timeout,
TimeUnit timeUnit) |
Bucket |
Cluster.openBucket(long timeout,
TimeUnit timeUnit)
Opens the default bucket with an empty password with a custom timeout.
|
Bucket |
CouchbaseCluster.openBucket(String name) |
Bucket |
Cluster.openBucket(String name)
Opens the bucket with the given name, using the default timeout and the password from the
Authenticator |
Bucket |
CouchbaseCluster.openBucket(String name,
List<Transcoder<? extends Document,?>> transcoders) |
Bucket |
Cluster.openBucket(String name,
List<Transcoder<? extends Document,?>> transcoders)
Opens the bucket with the given name, using the default timeout and the password from the
Authenticator |
Bucket |
CouchbaseCluster.openBucket(String name,
List<Transcoder<? extends Document,?>> transcoders,
long timeout,
TimeUnit timeUnit) |
Bucket |
Cluster.openBucket(String name,
List<Transcoder<? extends Document,?>> transcoders,
long timeout,
TimeUnit timeUnit)
Opens the bucket with the given name, using a custom timeout and the password from the
Authenticator |
Bucket |
CouchbaseCluster.openBucket(String name,
long timeout,
TimeUnit timeUnit) |
Bucket |
Cluster.openBucket(String name,
long timeout,
TimeUnit timeUnit)
Opens the bucket with the given name, using a custom timeout and the password from the
Authenticator |
Bucket |
CouchbaseCluster.openBucket(String name,
String password) |
Bucket |
Cluster.openBucket(String name,
String password)
Opens a bucket identified by its name and password with the default connect timeout.
|
Bucket |
CouchbaseCluster.openBucket(String name,
String password,
List<Transcoder<? extends Document,?>> transcoders) |
Bucket |
Cluster.openBucket(String name,
String password,
List<Transcoder<? extends Document,?>> transcoders)
Opens a bucket identified by its name and password with custom transcoders and with the default connect timeout.
|
Bucket |
CouchbaseCluster.openBucket(String name,
String password,
List<Transcoder<? extends Document,?>> transcoders,
long timeout,
TimeUnit timeUnit) |
Bucket |
Cluster.openBucket(String name,
String password,
List<Transcoder<? extends Document,?>> transcoders,
long timeout,
TimeUnit timeUnit)
Opens a bucket identified by its name and password with custom transcoders and with a custom timeout.
|
Bucket |
CouchbaseCluster.openBucket(String name,
String password,
long timeout,
TimeUnit timeUnit) |
Bucket |
Cluster.openBucket(String name,
String password,
long timeout,
TimeUnit timeUnit)
Opens a bucket identified by its name and password with a custom timeout.
|
Constructor and Description |
---|
CouchbaseArrayList(String id,
Bucket bucket)
|
CouchbaseArrayList(String id,
Bucket bucket,
Collection<? extends E> content)
|
CouchbaseArrayList(String id,
Bucket bucket,
E... content)
|
CouchbaseArraySet(String id,
Bucket bucket)
Create a new
CouchbaseArraySet , backed by the document identified by id in the given Couchbase bucket . |
CouchbaseArraySet(String id,
Bucket bucket,
Set<? extends T> initialData)
Create a new
CouchbaseArraySet , backed by the document identified by id in the given Couchbase bucket . |
CouchbaseMap(String id,
Bucket bucket)
|
CouchbaseMap(String id,
Bucket bucket,
Map<String,? extends V> data)
|
CouchbaseQueue(String id,
Bucket bucket)
|
CouchbaseQueue(String id,
Bucket bucket,
Collection<? extends E> content)
|
CouchbaseQueue(String id,
Bucket bucket,
E... content)
|
Constructor and Description |
---|
JsonArrayDocumentIterator(Bucket bucket,
String id) |
Modifier and Type | Method and Description |
---|---|
static BucketConsumer |
BucketConsumer.create(Bucket bucket) |
static BucketConsumer |
BucketConsumer.create(Bucket bucket,
BucketConsumer.StoreType storeType) |
Constructor and Description |
---|
CouchbaseRepository(Bucket bucket,
CouchbaseEnvironment environment) |
Modifier and Type | Method and Description |
---|---|
static NodeLocatorHelper |
NodeLocatorHelper.create(Bucket bucket)
Creates a new
NodeLocatorHelper , mapped on to the given Bucket . |
rx.Single<JsonDocument> |
TransparentReplicaGetHelper.getFirstPrimaryOrReplica(String id,
Bucket bucket)
Asynchronously fetch the document from the primary and if that operations fails try all the replicas and return the first document that comes back from them (using the environments KV timeout for both primary and replica).
|
rx.Single<JsonDocument> |
TransparentReplicaGetHelper.getFirstPrimaryOrReplica(String id,
Bucket bucket,
long timeout)
Asynchronously fetch the document from the primary and if that operations fails try all the replicas and return the first document that comes back from them (with a custom timeout value applied to both primary and replica).
|
rx.Single<JsonDocument> |
TransparentReplicaGetHelper.getFirstPrimaryOrReplica(String id,
Bucket bucket,
long primaryTimeout,
long replicaTimeout)
Asynchronously fetch the document from the primary and if that operations fails try all the replicas and return the first document that comes back from them (with custom primary and replica timeout values).
|
static <D extends Document<?>> |
TransparentReplicaGetHelper.getFirstPrimaryOrReplica(String id,
Class<D> target,
Bucket bucket)
Asynchronously fetch the document from the primary and if that operations fails try all the replicas and return the first document that comes back from them (using the environments KV timeout for both primary and replica).
|
static <D extends Document<?>> |
TransparentReplicaGetHelper.getFirstPrimaryOrReplica(String id,
Class<D> target,
Bucket bucket,
long timeout)
Asynchronously fetch the document from the primary and if that operations fails try all the replicas and return the first document that comes back from them (with a custom timeout value applied to both primary and replica).
|
static <D extends Document<?>> |
TransparentReplicaGetHelper.getFirstPrimaryOrReplica(String id,
Class<D> target,
Bucket bucket,
long primaryTimeout,
long replicaTimeout)
Asynchronously fetch the document from the primary and if that operations fails try all the replicas and return the first document that comes back from them.
|
Constructor and Description |
---|
DefaultSpatialViewResult(CouchbaseEnvironment env,
Bucket bucket,
rx.Observable<AsyncSpatialViewRow> rows,
boolean success,
rx.Observable<JsonObject> error,
JsonObject debug) |
DefaultViewResult(CouchbaseEnvironment env,
Bucket bucket,
rx.Observable<AsyncViewRow> rows,
int totalRows,
boolean success,
rx.Observable<JsonObject> error,
JsonObject debug) |
Copyright © 2015 Couchbase, Inc.