Package | Description |
---|---|
com.couchbase.client.core.io.netty.kv | |
com.couchbase.client.core.msg.kv | |
com.couchbase.client.core.service.kv |
Modifier and Type | Method and Description |
---|---|
static Optional<MutationToken> |
MemcacheProtocol.extractToken(boolean enabled,
short partition,
com.couchbase.client.core.deps.io.netty.buffer.ByteBuf msg,
String bucket)
Tries to extract the mutation token if the surround msg and environment allows for it.
|
Modifier and Type | Method and Description |
---|---|
Optional<MutationToken> |
AppendResponse.mutationToken() |
Optional<MutationToken> |
UpsertResponse.mutationToken() |
Optional<MutationToken> |
ReplaceResponse.mutationToken() |
Optional<MutationToken> |
SubdocMutateResponse.mutationToken() |
Optional<MutationToken> |
RemoveResponse.mutationToken() |
Optional<MutationToken> |
IncrementResponse.mutationToken() |
Optional<MutationToken> |
TouchResponse.mutationToken() |
Optional<MutationToken> |
InsertResponse.mutationToken() |
Optional<MutationToken> |
PrependResponse.mutationToken() |
Optional<MutationToken> |
DecrementResponse.mutationToken() |
Optional<MutationToken> |
UnlockResponse.mutationToken() |
Constructor and Description |
---|
AppendResponse(ResponseStatus status,
long cas,
Optional<MutationToken> mutationToken) |
DecrementResponse(ResponseStatus status,
long value,
long cas,
Optional<MutationToken> mutationToken) |
IncrementResponse(ResponseStatus status,
long value,
long cas,
Optional<MutationToken> mutationToken) |
PrependResponse(ResponseStatus status,
long cas,
Optional<MutationToken> mutationToken) |
SubdocMutateResponse(ResponseStatus status,
Optional<CouchbaseException> error,
SubDocumentField[] values,
long cas,
Optional<MutationToken> mutationToken) |
TouchResponse(ResponseStatus status,
long cas,
Optional<MutationToken> mutationToken) |
UnlockResponse(ResponseStatus status,
long cas,
Optional<MutationToken> mutationToken) |
Modifier and Type | Method and Description |
---|---|
Optional<MutationToken> |
ObserveContext.mutationToken() |
Constructor and Description |
---|
ObserveContext(CoreContext ctx,
Observe.ObservePersistTo persistTo,
Observe.ObserveReplicateTo replicateTo,
Optional<MutationToken> mutationToken,
long cas,
CollectionIdentifier collectionIdentifier,
String key,
boolean remove,
Duration timeout,
RequestSpan parentSpan) |
Copyright © 2020 Couchbase, Inc.. All rights reserved.