Uses of Class
com.couchbase.client.core.msg.kv.MutationToken
Package
Description
-
Uses of MutationToken in com.couchbase.client.core.api.kv
ModifierConstructorDescriptionCoreCounterResult
(CoreKvResponseMetadata meta, CoreKeyspace keyspace, String key, long cas, long content, Optional<MutationToken> mutationToken) CoreMutationResult
(CoreKvResponseMetadata meta, CoreKeyspace keyspace, String key, long cas, Optional<MutationToken> mutationToken) CoreSubdocMutateResult
(CoreKeyspace keyspace, String key, CoreKvResponseMetadata meta, long cas, Optional<MutationToken> mutationToken, List<SubDocumentField> fields) -
Uses of MutationToken in com.couchbase.client.core.io.netty.kv
Modifier and TypeMethodDescriptionstatic 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. -
Uses of MutationToken in com.couchbase.client.core.kv
Modifier and TypeMethodDescriptiondefault Map
<Short, MutationToken> CoreScanOptions.consistencyMap()
-
Uses of MutationToken in com.couchbase.client.core.msg.kv
Modifier and TypeMethodDescriptionMutationTokenAggregator.iterator()
AppendResponse.mutationToken()
DecrementResponse.mutationToken()
IncrementResponse.mutationToken()
InsertResponse.mutationToken()
PrependResponse.mutationToken()
RemoveResponse.mutationToken()
ReplaceResponse.mutationToken()
SubdocMutateResponse.mutationToken()
TouchResponse.mutationToken()
UnlockResponse.mutationToken()
UpsertResponse.mutationToken()
Modifier and TypeMethodDescriptionvoid
MutationTokenAggregator.add
(MutationToken token) Adds the token to the aggregator, unless there's already a token with the same bucket name and partition and a higher sequence number.Modifier and TypeMethodDescriptionstatic RangeScanCreateRequest
RangeScanCreateRequest.forRangeScan
(byte[] startTerm, CoreRangeScan rangeScan, CoreScanOptions options, short partition, CoreContext ctx, CollectionIdentifier collectionIdentifier, Map<Short, MutationToken> consistencyMap) static RangeScanCreateRequest
RangeScanCreateRequest.forSamplingScan
(CoreSamplingScan samplingScan, CoreScanOptions options, short partition, CoreContext ctx, CollectionIdentifier collectionIdentifier, Map<Short, MutationToken> consistencyMap) ModifierConstructorDescriptionAppendResponse
(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) TouchResponse
(ResponseStatus status, long cas, Optional<MutationToken> mutationToken) UnlockResponse
(ResponseStatus status, long cas, Optional<MutationToken> mutationToken) -
Uses of MutationToken in com.couchbase.client.core.service.kv
ModifierConstructorDescriptionObserveContext
(CoreContext ctx, Observe.ObservePersistTo persistTo, Observe.ObserveReplicateTo replicateTo, Optional<MutationToken> mutationToken, long cas, CollectionIdentifier collectionIdentifier, String key, boolean remove, Duration timeout, RequestSpan parentSpan)