Package com.couchbase.client.core.message.kv

Class GetAllMutationTokensRequest

java.lang.Object

com.couchbase.client.core.message.AbstractCouchbaseRequest

com.couchbase.client.core.message.kv.AbstractKeyValueRequest

com.couchbase.client.core.message.kv.GetAllMutationTokensRequest

All Implemented Interfaces:

CouchbaseMessage, CouchbaseRequest, BinaryRequest

@Experimental
public class GetAllMutationTokensRequest
extends AbstractKeyValueRequest

Get the current high sequence numbers one could initialize streams for all partitions that are located on the server, or use in ObserveViaMutationToken. You may retrict the returned values to a certain vBucket state. The state is supplied as an extra field and is fully optional.

Since:

1.2.2

Author:

Sergey Avseyev

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	GetAllMutationTokensRequest.PartitionState

Field Summary

Fields inherited from class com.couchbase.client.core.message.kv.AbstractKeyValueRequest

DEFAULT_PARTITION

Constructor Summary

Constructors

Constructor	Description
GetAllMutationTokensRequest(GetAllMutationTokensRequest.PartitionState partitionState, String hostname, String bucket)
GetAllMutationTokensRequest(String hostname, String bucket)

Method Summary

Modifier and Type	Method	Description
String	hostname()
short	partition()	The partition (vbucket) to use for this request.
GetAllMutationTokensRequest.PartitionState	partitionState()

Methods inherited from class com.couchbase.client.core.message.kv.AbstractKeyValueRequest

afterSpanSet, key, keyBytes, opaque, operationId, partition

Methods inherited from class com.couchbase.client.core.message.AbstractCouchbaseRequest

bucket, complete, creationTime, dispatchHostname, dispatchHostname, emit, fail, incrementRetryCount, isActive, lastLocalId, lastLocalId, lastLocalSocket, lastLocalSocket, lastRemoteSocket, lastRemoteSocket, maxRetryDuration, maxRetryDuration, observable, password, retryAfter, retryAfter, retryCount, retryDelay, retryDelay, span, span, subscriber, succeed, toString, username

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.couchbase.client.core.message.CouchbaseMessage

creationTime

Methods inherited from interface com.couchbase.client.core.message.CouchbaseRequest

bucket, complete, dispatchHostname, dispatchHostname, emit, fail, incrementRetryCount, isActive, lastLocalId, lastLocalId, lastLocalSocket, lastLocalSocket, lastRemoteSocket, lastRemoteSocket, maxRetryDuration, maxRetryDuration, observable, password, retryAfter, retryAfter, retryCount, retryDelay, retryDelay, span, span, subscriber, succeed, username

Constructor Detail

GetAllMutationTokensRequest

public GetAllMutationTokensRequest(String hostname,
                                   String bucket)

GetAllMutationTokensRequest

public GetAllMutationTokensRequest(GetAllMutationTokensRequest.PartitionState partitionState,
                                   String hostname,
                                   String bucket)

Method Detail

partitionState

public GetAllMutationTokensRequest.PartitionState partitionState()

hostname

public String hostname()

partition

public short partition()

Description copied from interface: BinaryRequest

The partition (vbucket) to use for this request.

Specified by:

partition in interface BinaryRequest

Overrides:

partition in class AbstractKeyValueRequest

Returns:

the partition to use.