Modifier and Type | Method and Description |
---|---|
JsonDocument |
Bucket.get(String id)
Retrieves a
JsonDocument by its unique ID with the default key/value timeout. |
JsonDocument |
CouchbaseBucket.get(String id) |
JsonDocument |
Bucket.get(String id,
long timeout,
TimeUnit timeUnit)
Retrieves a
JsonDocument by its unique ID with a custom timeout. |
JsonDocument |
CouchbaseBucket.get(String id,
long timeout,
TimeUnit timeUnit) |
JsonDocument |
Bucket.getAndLock(String id,
int lockTime)
Retrieve and lock a
JsonDocument by its unique ID with the default key/value timeout. |
JsonDocument |
CouchbaseBucket.getAndLock(String id,
int lockTime) |
JsonDocument |
Bucket.getAndLock(String id,
int lockTime,
long timeout,
TimeUnit timeUnit)
Retrieve and lock a
JsonDocument by its unique ID with a custom timeout. |
JsonDocument |
CouchbaseBucket.getAndLock(String id,
int lockTime,
long timeout,
TimeUnit timeUnit) |
JsonDocument |
Bucket.getAndTouch(String id,
int expiry)
Retrieve and touch a
JsonDocument by its unique ID with the default key/value timeout. |
JsonDocument |
CouchbaseBucket.getAndTouch(String id,
int expiry) |
JsonDocument |
Bucket.getAndTouch(String id,
int expiry,
long timeout,
TimeUnit timeUnit)
Retrieve and touch a
JsonDocument by its unique ID with the a custom timeout. |
JsonDocument |
CouchbaseBucket.getAndTouch(String id,
int expiry,
long timeout,
TimeUnit timeUnit) |
JsonDocument |
Bucket.remove(String id)
Removes a
Document from the Server identified by its ID with the default key/value timeout. |
JsonDocument |
CouchbaseBucket.remove(String id) |
JsonDocument |
Bucket.remove(String id,
long timeout,
TimeUnit timeUnit)
Removes a
Document from the Server identified by its ID with a custom timeout. |
JsonDocument |
CouchbaseBucket.remove(String id,
long timeout,
TimeUnit timeUnit) |
JsonDocument |
Bucket.remove(String id,
PersistTo persistTo)
Removes a
Document from the Server by its ID and apply a durability requirement with the default key/value timeout. |
JsonDocument |
CouchbaseBucket.remove(String id,
PersistTo persistTo) |
JsonDocument |
Bucket.remove(String id,
PersistTo persistTo,
long timeout,
TimeUnit timeUnit)
Removes a
Document from the Server by its ID and apply a durability requirement with a custom timeout. |
JsonDocument |
CouchbaseBucket.remove(String id,
PersistTo persistTo,
long timeout,
TimeUnit timeUnit) |
JsonDocument |
Bucket.remove(String id,
PersistTo persistTo,
ReplicateTo replicateTo)
Removes a
Document from the Server by its ID and apply a durability requirement with the default key/value timeout. |
JsonDocument |
CouchbaseBucket.remove(String id,
PersistTo persistTo,
ReplicateTo replicateTo) |
JsonDocument |
Bucket.remove(String id,
PersistTo persistTo,
ReplicateTo replicateTo,
long timeout,
TimeUnit timeUnit)
Removes a
Document from the Server by its ID and apply a durability requirement with a custom timeout. |
JsonDocument |
CouchbaseBucket.remove(String id,
PersistTo persistTo,
ReplicateTo replicateTo,
long timeout,
TimeUnit timeUnit) |
JsonDocument |
Bucket.remove(String id,
ReplicateTo replicateTo)
Removes a
Document from the Server by its ID and apply a durability requirement with the default key/value timeout. |
JsonDocument |
CouchbaseBucket.remove(String id,
ReplicateTo replicateTo) |
JsonDocument |
Bucket.remove(String id,
ReplicateTo replicateTo,
long timeout,
TimeUnit timeUnit)
Removes a
Document from the Server by its ID and apply a durability requirement with a custom timeout. |
JsonDocument |
CouchbaseBucket.remove(String id,
ReplicateTo replicateTo,
long timeout,
TimeUnit timeUnit) |
Modifier and Type | Method and Description |
---|---|
rx.Observable<JsonDocument> |
CouchbaseAsyncBucket.get(String id) |
rx.Observable<JsonDocument> |
AsyncBucket.get(String id)
Retrieves a
JsonDocument by its unique ID. |
rx.Observable<JsonDocument> |
CouchbaseAsyncBucket.get(String id,
long timeout,
TimeUnit timeUnit) |
rx.Observable<JsonDocument> |
AsyncBucket.get(String id,
long timeout,
TimeUnit timeUnit)
Retrieves a
JsonDocument by its unique ID with a custom timeout. |
rx.Observable<JsonDocument> |
CouchbaseAsyncBucket.getAndLock(String id,
int lockTime) |
rx.Observable<JsonDocument> |
AsyncBucket.getAndLock(String id,
int lockTime)
Retrieve and lock a
JsonDocument by its unique ID. |
rx.Observable<JsonDocument> |
CouchbaseAsyncBucket.getAndLock(String id,
int lockTime,
long timeout,
TimeUnit timeUnit) |
rx.Observable<JsonDocument> |
AsyncBucket.getAndLock(String id,
int lockTime,
long timeout,
TimeUnit timeUnit)
Retrieve and lock a
JsonDocument by its unique ID with a custom timeout. |
rx.Observable<JsonDocument> |
CouchbaseAsyncBucket.getAndTouch(String id,
int expiry) |
rx.Observable<JsonDocument> |
AsyncBucket.getAndTouch(String id,
int expiry)
Retrieve and touch a
JsonDocument by its unique ID. |
rx.Observable<JsonDocument> |
CouchbaseAsyncBucket.getAndTouch(String id,
int expiry,
long timeout,
TimeUnit timeUnit) |
rx.Observable<JsonDocument> |
AsyncBucket.getAndTouch(String id,
int expiry,
long timeout,
TimeUnit timeUnit)
Retrieve and touch a
JsonDocument by its unique ID with a custom timeout. |
Iterator<JsonDocument> |
Bucket.getFromReplica(String id)
Retrieves one or more, possibly stale, representations of a
JsonDocument by its unique ID with the default timeout. |
Iterator<JsonDocument> |
CouchbaseBucket.getFromReplica(String id) |
Iterator<JsonDocument> |
Bucket.getFromReplica(String id,
long timeout,
TimeUnit timeUnit)
Retrieves one or more, possibly stale, representations of a
JsonDocument by its unique ID with a custom timeout. |
Iterator<JsonDocument> |
CouchbaseBucket.getFromReplica(String id,
long timeout,
TimeUnit timeUnit) |
List<JsonDocument> |
Bucket.getFromReplica(String id,
ReplicaMode type)
Retrieves one or more, possibly stale, representations of a
JsonDocument by its unique ID with the default timeout. |
List<JsonDocument> |
CouchbaseBucket.getFromReplica(String id,
ReplicaMode type) |
rx.Observable<JsonDocument> |
CouchbaseAsyncBucket.getFromReplica(String id,
ReplicaMode type) |
rx.Observable<JsonDocument> |
AsyncBucket.getFromReplica(String id,
ReplicaMode type)
Retrieves one or more, possibly stale, representations of a
JsonDocument by its unique ID. |
List<JsonDocument> |
Bucket.getFromReplica(String id,
ReplicaMode type,
long timeout,
TimeUnit timeUnit)
Retrieves one or more, possibly stale, representations of a
JsonDocument by its unique ID with a custom timeout. |
List<JsonDocument> |
CouchbaseBucket.getFromReplica(String id,
ReplicaMode type,
long timeout,
TimeUnit timeUnit) |
rx.Observable<JsonDocument> |
CouchbaseAsyncBucket.getFromReplica(String id,
ReplicaMode type,
long timeout,
TimeUnit timeUnit) |
rx.Observable<JsonDocument> |
AsyncBucket.getFromReplica(String id,
ReplicaMode type,
long timeout,
TimeUnit timeUnit)
Retrieves one or more, possibly stale, representations of a
JsonDocument by its unique ID. |
rx.Observable<JsonDocument> |
CouchbaseAsyncBucket.remove(String id) |
rx.Observable<JsonDocument> |
AsyncBucket.remove(String id)
Removes a
Document from the Server identified by its ID. |
rx.Observable<JsonDocument> |
CouchbaseAsyncBucket.remove(String id,
long timeout,
TimeUnit timeUnit) |
rx.Observable<JsonDocument> |
AsyncBucket.remove(String id,
long timeout,
TimeUnit timeUnit)
Removes a
Document from the Server identified by its ID. |
rx.Observable<JsonDocument> |
CouchbaseAsyncBucket.remove(String id,
PersistTo persistTo) |
rx.Observable<JsonDocument> |
AsyncBucket.remove(String id,
PersistTo persistTo)
Removes a
Document from the Server by its ID and apply a durability requirement. |
rx.Observable<JsonDocument> |
CouchbaseAsyncBucket.remove(String id,
PersistTo persistTo,
long timeout,
TimeUnit timeUnit) |
rx.Observable<JsonDocument> |
AsyncBucket.remove(String id,
PersistTo persistTo,
long timeout,
TimeUnit timeUnit)
Removes a
Document from the Server by its ID and apply a durability requirement. |
rx.Observable<JsonDocument> |
CouchbaseAsyncBucket.remove(String id,
PersistTo persistTo,
ReplicateTo replicateTo) |
rx.Observable<JsonDocument> |
AsyncBucket.remove(String id,
PersistTo persistTo,
ReplicateTo replicateTo)
Removes a
Document from the Server by its ID and apply a durability requirement. |
rx.Observable<JsonDocument> |
CouchbaseAsyncBucket.remove(String id,
PersistTo persistTo,
ReplicateTo replicateTo,
long timeout,
TimeUnit timeUnit) |
rx.Observable<JsonDocument> |
AsyncBucket.remove(String id,
PersistTo persistTo,
ReplicateTo replicateTo,
long timeout,
TimeUnit timeUnit)
Removes a
Document from the Server by its ID and apply a durability requirement. |
rx.Observable<JsonDocument> |
CouchbaseAsyncBucket.remove(String id,
ReplicateTo replicateTo) |
rx.Observable<JsonDocument> |
AsyncBucket.remove(String id,
ReplicateTo replicateTo)
Removes a
Document from the Server by its ID and apply a durability requirement. |
rx.Observable<JsonDocument> |
CouchbaseAsyncBucket.remove(String id,
ReplicateTo replicateTo,
long timeout,
TimeUnit timeUnit) |
rx.Observable<JsonDocument> |
AsyncBucket.remove(String id,
ReplicateTo replicateTo,
long timeout,
TimeUnit timeUnit)
Removes a
Document from the Server by its ID and apply a durability requirement. |
Modifier and Type | Method and Description |
---|---|
static rx.functions.Func1<JsonDocument,DocumentFragment<Mutation>> |
ResultMappingUtils.getMapFullDocResultToSubDocFn(Mutation mutation)
Creates anonymous function for mapping full JsonDocument insert result to document fragment result
|
Modifier and Type | Method and Description |
---|---|
static JsonDocument |
JsonDocument.create(String id)
Creates a
JsonDocument which the document id. |
static JsonDocument |
JsonDocument.create(String id,
int expiry,
JsonObject content)
Creates a
JsonDocument which the document id, JSON content and the expiration time. |
static JsonDocument |
JsonDocument.create(String id,
int expiry,
JsonObject content,
long cas)
Creates a
JsonDocument which the document id, JSON content, CAS value, expiration time and status code. |
static JsonDocument |
JsonDocument.create(String id,
int expiry,
JsonObject content,
long cas,
MutationToken mutationToken)
Creates a
JsonDocument which the document id, JSON content, CAS value, expiration time and status code. |
static JsonDocument |
JsonDocument.create(String id,
JsonObject content)
Creates a
JsonDocument which the document id and JSON content. |
static JsonDocument |
JsonDocument.create(String id,
JsonObject content,
long cas)
Creates a
JsonDocument which the document id, JSON content and the CAS value. |
static JsonDocument |
JsonDocument.from(JsonDocument doc,
JsonObject content)
Creates a copy from a different
JsonDocument , but changes the content. |
static JsonDocument |
JsonDocument.from(JsonDocument doc,
long cas)
Creates a copy from a different
JsonDocument , but changes the CAS value. |
static JsonDocument |
JsonDocument.from(JsonDocument doc,
String id)
Creates a copy from a different
JsonDocument , but changes the document ID. |
static JsonDocument |
JsonDocument.from(JsonDocument doc,
String id,
JsonObject content)
Creates a copy from a different
JsonDocument , but changes the document ID and content. |
Modifier and Type | Method and Description |
---|---|
static JsonDocument |
JsonDocument.from(JsonDocument doc,
JsonObject content)
Creates a copy from a different
JsonDocument , but changes the content. |
static JsonDocument |
JsonDocument.from(JsonDocument doc,
long cas)
Creates a copy from a different
JsonDocument , but changes the CAS value. |
static JsonDocument |
JsonDocument.from(JsonDocument doc,
String id)
Creates a copy from a different
JsonDocument , but changes the document ID. |
static JsonDocument |
JsonDocument.from(JsonDocument doc,
String id,
JsonObject content)
Creates a copy from a different
JsonDocument , but changes the document ID and content. |
Modifier and Type | Method and Description |
---|---|
JsonDocument |
DefaultEntityConverter.fromEntity(EntityDocument<Object> source) |
Modifier and Type | Method and Description |
---|---|
<T> EntityDocument<T> |
DefaultEntityConverter.toEntity(JsonDocument source,
Class<T> clazz) |
Modifier and Type | Method and Description |
---|---|
protected JsonDocument |
JsonTranscoder.doDecode(String id,
com.couchbase.client.deps.io.netty.buffer.ByteBuf content,
long cas,
int expiry,
int flags,
ResponseStatus status) |
JsonDocument |
JsonTranscoder.newDocument(String id,
int expiry,
JsonObject content,
long cas) |
JsonDocument |
JsonTranscoder.newDocument(String id,
int expiry,
JsonObject content,
long cas,
MutationToken mutationToken) |
Modifier and Type | Method and Description |
---|---|
Class<JsonDocument> |
JsonTranscoder.documentType() |
Modifier and Type | Method and Description |
---|---|
protected Tuple2<com.couchbase.client.deps.io.netty.buffer.ByteBuf,Integer> |
JsonTranscoder.doEncode(JsonDocument document) |
Modifier and Type | Method and Description |
---|---|
protected JsonDocument |
JsonCryptoTranscoder.doDecode(String id,
com.couchbase.client.deps.io.netty.buffer.ByteBuf content,
long cas,
int expiry,
int flags,
ResponseStatus status) |
JsonDocument |
JsonCryptoTranscoder.newDocument(String id,
int expiry,
JsonObject content,
long cas) |
JsonDocument |
JsonCryptoTranscoder.newDocument(String id,
int expiry,
JsonObject content,
long cas,
MutationToken mutationToken) |
Modifier and Type | Method and Description |
---|---|
Class<JsonDocument> |
JsonCryptoTranscoder.documentType() |
Modifier and Type | Method and Description |
---|---|
protected Tuple2<com.couchbase.client.deps.io.netty.buffer.ByteBuf,Integer> |
JsonCryptoTranscoder.doEncode(JsonDocument document) |
Modifier and Type | Method and Description |
---|---|
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).
|
Modifier and Type | Method and Description |
---|---|
JsonDocument |
SpatialViewRow.document()
Load the underlying document, if not reduced with the default view timeout.
|
JsonDocument |
DefaultSpatialViewRow.document() |
JsonDocument |
DefaultViewRow.document() |
JsonDocument |
ViewRow.document()
Load the underlying document, if not reduced with the default view timeout.
|
JsonDocument |
SpatialViewRow.document(long timeout,
TimeUnit timeUnit)
Load the underlying document, if not reduced with a custom timeout.
|
JsonDocument |
DefaultSpatialViewRow.document(long timeout,
TimeUnit timeUnit) |
JsonDocument |
DefaultViewRow.document(long timeout,
TimeUnit timeUnit) |
JsonDocument |
ViewRow.document(long timeout,
TimeUnit timeUnit)
Load the underlying document, if not reduced with a custom timeout.
|
Modifier and Type | Method and Description |
---|---|
rx.Observable<JsonDocument> |
DefaultAsyncSpatialViewRow.document() |
rx.Observable<JsonDocument> |
DefaultAsyncViewRow.document() |
rx.Observable<JsonDocument> |
AsyncSpatialViewRow.document()
Load the underlying document.
|
rx.Observable<JsonDocument> |
AsyncViewRow.document()
Load the underlying document, if not reduced.
|
Copyright © 2015 Couchbase, Inc.