Package com.couchbase.client.core.msg.kv
Class ReplicaGetRequest
- java.lang.Object
-
- com.couchbase.client.core.msg.BaseRequest<R>
-
- com.couchbase.client.core.msg.kv.BaseKeyValueRequest<GetResponse>
-
- com.couchbase.client.core.msg.kv.GetRequest
-
- com.couchbase.client.core.msg.kv.ReplicaGetRequest
-
- All Implemented Interfaces:
KeyValueRequest<GetResponse>
,Request<GetResponse>
,ScopedRequest
public class ReplicaGetRequest extends GetRequest
-
-
Constructor Summary
Constructors Constructor Description ReplicaGetRequest(String key, Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, short replica)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description com.couchbase.client.core.deps.io.netty.buffer.ByteBuf
encode(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc, int opaque, ChannelContext ctx)
Encode this request with the given allocator and opaque.short
replica()
-
Methods inherited from class com.couchbase.client.core.msg.kv.GetRequest
decode
-
Methods inherited from class com.couchbase.client.core.msg.kv.BaseKeyValueRequest
bucket, collectionIdentifier, encodedKeyWithCollection, key, partition, partition, serviceContext, serviceType
-
Methods inherited from class com.couchbase.client.core.msg.BaseRequest
cancel, cancellationReason, cancelled, completed, context, fail, failed, id, response, retryStrategy, succeed, succeeded, timeout
-
-
-
-
Constructor Detail
-
ReplicaGetRequest
public ReplicaGetRequest(String key, Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, short replica)
-
-
Method Detail
-
replica
public short replica()
-
encode
public com.couchbase.client.core.deps.io.netty.buffer.ByteBuf encode(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc, int opaque, ChannelContext ctx)
Description copied from interface:KeyValueRequest
Encode this request with the given allocator and opaque.- Specified by:
encode
in interfaceKeyValueRequest<GetResponse>
- Overrides:
encode
in classGetRequest
- Parameters:
alloc
- the allocator where to grab the buffers from.opaque
- the opaque value to use.ctx
- more encode context.- Returns:
- the encoded request as a
ByteBuf
.
-
-