Package com.couchbase.client.core.msg.kv

Class RangeScanCancelRequest

java.lang.Object

com.couchbase.client.core.msg.BaseRequest<R>

com.couchbase.client.core.msg.kv.BaseKeyValueRequest<R>

com.couchbase.client.core.msg.kv.PredeterminedPartitionRequest<RangeScanCancelResponse>

com.couchbase.client.core.msg.kv.RangeScanCancelRequest

All Implemented Interfaces:

KeyValueRequest<RangeScanCancelResponse>, Request<RangeScanCancelResponse>, ScopedRequest

@Internal
public class RangeScanCancelRequest
extends PredeterminedPartitionRequest<RangeScanCancelResponse>

Constructor Summary

Constructors

Constructor	Description
RangeScanCancelRequest(CoreRangeScanId id, CoreScanOptions options, short partition, CoreContext ctx, CollectionIdentifier collectionIdentifier)

Method Summary

Modifier and Type	Method	Description
RangeScanCancelResponse	decode(com.couchbase.client.core.deps.io.netty.buffer.ByteBuf response, KeyValueChannelContext ctx)	Decode the encoded response into its message representation.
com.couchbase.client.core.deps.io.netty.buffer.ByteBuf	encode(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc, int opaque, KeyValueChannelContext ctx)	Encode this request with the given allocator and opaque.

Methods inherited from class com.couchbase.client.core.msg.kv.PredeterminedPartitionRequest

partition, partition

Methods inherited from class com.couchbase.client.core.msg.kv.BaseKeyValueRequest

bucket, collectionIdentifier, encodedExternalKeyWithCollection, encodedKeyWithCollection, errorCode, indicateRejectedWithNotMyVbucket, key, nextOpaque, opaque, operationId, rejectedWithNotMyVbucket, serviceContext, serviceType

Methods inherited from class com.couchbase.client.core.msg.BaseRequest

absoluteTimeout, cancel, cancellationReason, cancelled, completed, context, createdAt, fail, failed, id, requestSpan, response, retryStrategy, succeed, succeeded, timeout, timeoutElapsed, timeoutRegistration

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.couchbase.client.core.msg.Request

absoluteTimeout, cancel, cancel, cancellationReason, cancelled, completed, context, createdAt, fail, failed, id, idempotent, name, requestSpan, response, retryStrategy, succeed, succeeded, target, timeout, timeoutElapsed, timeoutRegistration

Constructor Details

RangeScanCancelRequest

public RangeScanCancelRequest(CoreRangeScanId id,
 CoreScanOptions options,
 short partition,
 CoreContext ctx,
 CollectionIdentifier collectionIdentifier)

Method Details

encode

public com.couchbase.client.core.deps.io.netty.buffer.ByteBuf encode(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc,
 int opaque,
 KeyValueChannelContext ctx)

Description copied from interface: KeyValueRequest

Encode this request with the given allocator and opaque.

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.

decode

public RangeScanCancelResponse decode(com.couchbase.client.core.deps.io.netty.buffer.ByteBuf response,
 KeyValueChannelContext ctx)

Description copied from interface: KeyValueRequest

Decode the encoded response into its message representation.

Parameters:

response - the response to decode.

Returns:

the decoded response as the generic type R.