Interface KeyValueRequest<R extends Response>

    • Method Detail

      • partition

        short partition()
        Reads the currently set partition this request is targeted against.
      • partition

        void partition​(short partition)
        Allows to set the partition used for this request.
        Parameters:
        partition - the partition to set.
      • encode

        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.
        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

        R decode​(com.couchbase.client.core.deps.io.netty.buffer.ByteBuf response,
                 KeyValueChannelContext ctx)
        Decode the encoded response into its message representation.
        Parameters:
        response - the response to decode.
        Returns:
        the decoded response as the generic type R.
      • key

        byte[] key()
        The key of the kv request.
        Returns:
        the key of the request.
      • opaque

        int opaque()
      • rejectedWithNotMyVbucket

        int rejectedWithNotMyVbucket()
        Returns the number of times this request has been rejected with a not my vbucket response before.
      • indicateRejectedWithNotMyVbucket

        void indicateRejectedWithNotMyVbucket()
        Increments the counter indicating that this request has been rejected with a not my vbucket response.