| Package | Description |
|---|---|
| com.couchbase.client.core.io.netty.kv | |
| com.couchbase.client.core.msg.kv |
| Modifier and Type | Method and Description |
|---|---|
static com.couchbase.client.core.deps.io.netty.buffer.ByteBuf |
MemcacheProtocol.mutationFlexibleExtras(KeyValueRequest<?> request,
KeyValueChannelContext ctx,
com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc,
Optional<DurabilityLevel> durabilityLevel) |
static com.couchbase.client.core.deps.io.netty.buffer.ByteBuf |
MemcacheProtocol.mutationFlexibleExtras(KeyValueRequest<?> request,
KeyValueChannelContext ctx,
com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc,
Optional<DurabilityLevel> durabilityLevel,
boolean preserveExpiry) |
| Modifier and Type | Method and Description |
|---|---|
GetAndLockResponse |
GetAndLockRequest.decode(com.couchbase.client.core.deps.io.netty.buffer.ByteBuf response,
KeyValueChannelContext ctx) |
SubdocGetResponse |
SubdocGetRequest.decode(com.couchbase.client.core.deps.io.netty.buffer.ByteBuf response,
KeyValueChannelContext ctx) |
PrependResponse |
PrependRequest.decode(com.couchbase.client.core.deps.io.netty.buffer.ByteBuf response,
KeyValueChannelContext ctx) |
InsertResponse |
InsertRequest.decode(com.couchbase.client.core.deps.io.netty.buffer.ByteBuf response,
KeyValueChannelContext ctx) |
GetCollectionIdResponse |
GetCollectionIdRequest.decode(com.couchbase.client.core.deps.io.netty.buffer.ByteBuf response,
KeyValueChannelContext ctx) |
RemoveResponse |
RemoveRequest.decode(com.couchbase.client.core.deps.io.netty.buffer.ByteBuf response,
KeyValueChannelContext ctx) |
GetAndTouchResponse |
GetAndTouchRequest.decode(com.couchbase.client.core.deps.io.netty.buffer.ByteBuf response,
KeyValueChannelContext ctx) |
CarrierBucketConfigResponse |
CarrierBucketConfigRequest.decode(com.couchbase.client.core.deps.io.netty.buffer.ByteBuf response,
KeyValueChannelContext ctx) |
ObserveViaSeqnoResponse |
ObserveViaSeqnoRequest.decode(com.couchbase.client.core.deps.io.netty.buffer.ByteBuf response,
KeyValueChannelContext ctx) |
KvPingResponse |
KvPingRequest.decode(com.couchbase.client.core.deps.io.netty.buffer.ByteBuf response,
KeyValueChannelContext ctx) |
CarrierGlobalConfigResponse |
CarrierGlobalConfigRequest.decode(com.couchbase.client.core.deps.io.netty.buffer.ByteBuf response,
KeyValueChannelContext ctx) |
DecrementResponse |
DecrementRequest.decode(com.couchbase.client.core.deps.io.netty.buffer.ByteBuf response,
KeyValueChannelContext ctx) |
UpsertResponse |
UpsertRequest.decode(com.couchbase.client.core.deps.io.netty.buffer.ByteBuf response,
KeyValueChannelContext ctx) |
SubdocMutateResponse |
SubdocMutateRequest.decode(com.couchbase.client.core.deps.io.netty.buffer.ByteBuf response,
KeyValueChannelContext ctx) |
IncrementResponse |
IncrementRequest.decode(com.couchbase.client.core.deps.io.netty.buffer.ByteBuf response,
KeyValueChannelContext ctx) |
GetMetaResponse |
GetMetaRequest.decode(com.couchbase.client.core.deps.io.netty.buffer.ByteBuf response,
KeyValueChannelContext ctx) |
R |
KeyValueRequest.decode(com.couchbase.client.core.deps.io.netty.buffer.ByteBuf response,
KeyValueChannelContext ctx)
Decode the encoded response into its message representation.
|
NoopResponse |
NoopRequest.decode(com.couchbase.client.core.deps.io.netty.buffer.ByteBuf response,
KeyValueChannelContext ctx) |
MultiObserveViaCasResponse |
MultiObserveViaCasRequest.decode(com.couchbase.client.core.deps.io.netty.buffer.ByteBuf response,
KeyValueChannelContext ctx) |
UnlockResponse |
UnlockRequest.decode(com.couchbase.client.core.deps.io.netty.buffer.ByteBuf response,
KeyValueChannelContext ctx) |
TouchResponse |
TouchRequest.decode(com.couchbase.client.core.deps.io.netty.buffer.ByteBuf response,
KeyValueChannelContext ctx) |
ReplaceResponse |
ReplaceRequest.decode(com.couchbase.client.core.deps.io.netty.buffer.ByteBuf response,
KeyValueChannelContext ctx) |
GetResponse |
GetRequest.decode(com.couchbase.client.core.deps.io.netty.buffer.ByteBuf response,
KeyValueChannelContext ctx) |
RangeScanCreateResponse |
RangeScanCreateRequest.decode(com.couchbase.client.core.deps.io.netty.buffer.ByteBuf response,
KeyValueChannelContext ctx) |
AppendResponse |
AppendRequest.decode(com.couchbase.client.core.deps.io.netty.buffer.ByteBuf response,
KeyValueChannelContext ctx) |
RangeScanCancelResponse |
RangeScanCancelRequest.decode(com.couchbase.client.core.deps.io.netty.buffer.ByteBuf response,
KeyValueChannelContext ctx) |
RangeScanContinueResponse |
RangeScanContinueRequest.decode(com.couchbase.client.core.deps.io.netty.buffer.ByteBuf response,
KeyValueChannelContext ctx) |
ObserveViaCasResponse |
ObserveViaCasRequest.decode(com.couchbase.client.core.deps.io.netty.buffer.ByteBuf response,
KeyValueChannelContext ctx) |
GetCollectionManifestResponse |
GetCollectionManifestRequest.decode(com.couchbase.client.core.deps.io.netty.buffer.ByteBuf response,
KeyValueChannelContext ctx) |
com.couchbase.client.core.deps.io.netty.buffer.ByteBuf |
GetAndLockRequest.encode(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc,
int opaque,
KeyValueChannelContext ctx) |
com.couchbase.client.core.deps.io.netty.buffer.ByteBuf |
SubdocGetRequest.encode(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc,
int opaque,
KeyValueChannelContext ctx) |
com.couchbase.client.core.deps.io.netty.buffer.ByteBuf |
PrependRequest.encode(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc,
int opaque,
KeyValueChannelContext ctx) |
com.couchbase.client.core.deps.io.netty.buffer.ByteBuf |
InsertRequest.encode(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc,
int opaque,
KeyValueChannelContext ctx) |
com.couchbase.client.core.deps.io.netty.buffer.ByteBuf |
GetCollectionIdRequest.encode(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc,
int opaque,
KeyValueChannelContext ctx) |
com.couchbase.client.core.deps.io.netty.buffer.ByteBuf |
ReplicaGetRequest.encode(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc,
int opaque,
KeyValueChannelContext ctx) |
com.couchbase.client.core.deps.io.netty.buffer.ByteBuf |
RemoveRequest.encode(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc,
int opaque,
KeyValueChannelContext ctx) |
com.couchbase.client.core.deps.io.netty.buffer.ByteBuf |
GetAndTouchRequest.encode(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc,
int opaque,
KeyValueChannelContext ctx) |
com.couchbase.client.core.deps.io.netty.buffer.ByteBuf |
CarrierBucketConfigRequest.encode(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc,
int opaque,
KeyValueChannelContext ctx) |
com.couchbase.client.core.deps.io.netty.buffer.ByteBuf |
ObserveViaSeqnoRequest.encode(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc,
int opaque,
KeyValueChannelContext ctx) |
com.couchbase.client.core.deps.io.netty.buffer.ByteBuf |
CarrierGlobalConfigRequest.encode(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc,
int opaque,
KeyValueChannelContext ctx) |
com.couchbase.client.core.deps.io.netty.buffer.ByteBuf |
DecrementRequest.encode(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc,
int opaque,
KeyValueChannelContext ctx) |
com.couchbase.client.core.deps.io.netty.buffer.ByteBuf |
UpsertRequest.encode(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc,
int opaque,
KeyValueChannelContext ctx) |
com.couchbase.client.core.deps.io.netty.buffer.ByteBuf |
SubdocMutateRequest.encode(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc,
int opaque,
KeyValueChannelContext ctx) |
com.couchbase.client.core.deps.io.netty.buffer.ByteBuf |
IncrementRequest.encode(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc,
int opaque,
KeyValueChannelContext ctx) |
com.couchbase.client.core.deps.io.netty.buffer.ByteBuf |
GetMetaRequest.encode(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc,
int opaque,
KeyValueChannelContext ctx) |
com.couchbase.client.core.deps.io.netty.buffer.ByteBuf |
KeyValueRequest.encode(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc,
int opaque,
KeyValueChannelContext ctx)
Encode this request with the given allocator and opaque.
|
com.couchbase.client.core.deps.io.netty.buffer.ByteBuf |
NoopRequest.encode(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc,
int opaque,
KeyValueChannelContext ctx) |
com.couchbase.client.core.deps.io.netty.buffer.ByteBuf |
MultiObserveViaCasRequest.encode(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc,
int opaque,
KeyValueChannelContext ctx) |
com.couchbase.client.core.deps.io.netty.buffer.ByteBuf |
UnlockRequest.encode(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc,
int opaque,
KeyValueChannelContext ctx) |
com.couchbase.client.core.deps.io.netty.buffer.ByteBuf |
TouchRequest.encode(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc,
int opaque,
KeyValueChannelContext ctx) |
com.couchbase.client.core.deps.io.netty.buffer.ByteBuf |
ReplaceRequest.encode(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc,
int opaque,
KeyValueChannelContext ctx) |
com.couchbase.client.core.deps.io.netty.buffer.ByteBuf |
GetRequest.encode(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc,
int opaque,
KeyValueChannelContext ctx) |
com.couchbase.client.core.deps.io.netty.buffer.ByteBuf |
RangeScanCreateRequest.encode(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc,
int opaque,
KeyValueChannelContext ctx) |
com.couchbase.client.core.deps.io.netty.buffer.ByteBuf |
AppendRequest.encode(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc,
int opaque,
KeyValueChannelContext ctx) |
com.couchbase.client.core.deps.io.netty.buffer.ByteBuf |
RangeScanCancelRequest.encode(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc,
int opaque,
KeyValueChannelContext ctx) |
com.couchbase.client.core.deps.io.netty.buffer.ByteBuf |
RangeScanContinueRequest.encode(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc,
int opaque,
KeyValueChannelContext ctx) |
com.couchbase.client.core.deps.io.netty.buffer.ByteBuf |
ObserveViaCasRequest.encode(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc,
int opaque,
KeyValueChannelContext ctx) |
com.couchbase.client.core.deps.io.netty.buffer.ByteBuf |
GetCollectionManifestRequest.encode(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc,
int opaque,
KeyValueChannelContext ctx) |
protected com.couchbase.client.core.deps.io.netty.buffer.ByteBuf |
BaseKeyValueRequest.encodedExternalKeyWithCollection(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc,
KeyValueChannelContext ctx,
byte[] key)
Encodes a given key with the collection prefix if needed.
|
protected com.couchbase.client.core.deps.io.netty.buffer.ByteBuf |
BaseKeyValueRequest.encodedKeyWithCollection(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc,
KeyValueChannelContext ctx)
This method returns an encoded key with or without the collection prefix, depending on the
context provided.
|
Copyright © 2024 Couchbase, Inc.. All rights reserved.