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 Details
-
GetAllMutationTokensRequest
-
GetAllMutationTokensRequest
public GetAllMutationTokensRequest(GetAllMutationTokensRequest.PartitionState partitionState, String hostname, String bucket)
-
-
Method Details
-
partitionState
-
hostname
-
partition
public short partition()Description copied from interface:BinaryRequest
The partition (vbucket) to use for this request.- Specified by:
partition
in interfaceBinaryRequest
- Overrides:
partition
in classAbstractKeyValueRequest
- Returns:
- the partition to use.
-