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

@InterfaceStability.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 and Description
static class	GetAllMutationTokensRequest.PartitionState

Field Summary

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

DEFAULT_PARTITION

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
NetworkAddress	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

key, keyBytes, opaque, partition

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

bucket, creationTime, dispatchHostname, dispatchHostname, incrementRetryCount, isActive, maxRetryDuration, maxRetryDuration, observable, password, retryAfter, retryAfter, retryCount, retryDelay, retryDelay, subscriber, 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.CouchbaseRequest

bucket, dispatchHostname, dispatchHostname, incrementRetryCount, isActive, maxRetryDuration, maxRetryDuration, observable, password, retryAfter, retryAfter, retryCount, retryDelay, retryDelay, subscriber, username

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

creationTime

Constructor Detail

GetAllMutationTokensRequest

public GetAllMutationTokensRequest(NetworkAddress hostname,
                                   String bucket)

GetAllMutationTokensRequest

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

Method Detail

partitionState

public GetAllMutationTokensRequest.PartitionState partitionState()

hostname

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