@InterfaceStability.Experimental @InterfaceAudience.Private public class StreamRequestRequest extends AbstractDCPRequest
Stream request.
Sent by the consumer side to the producer specifying that the consumer wants to create a vBucket stream. In order to initiate multiple stream the consumer needs to send multiple commands.
DEFAULT_PARTITION
Constructor and Description |
---|
StreamRequestRequest(short partition,
long vbucketUUID,
long startSequenceNumber,
long endSequenceNumber,
long snapshotStartSequenceNumber,
long snapshotEndSequenceNumber,
String bucket,
String password,
DCPConnection connection) |
Modifier and Type | Method and Description |
---|---|
DCPConnection |
connection() |
long |
endSequenceNumber() |
long |
snapshotEndSequenceNumber() |
long |
snapshotStartSequenceNumber() |
long |
startSequenceNumber() |
long |
vbucketUUID() |
partition, partition, toString
bucket, creationTime, incrementRetryCount, observable, password, retryCount
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
bucket, incrementRetryCount, observable, password, retryCount
creationTime
public StreamRequestRequest(short partition, long vbucketUUID, long startSequenceNumber, long endSequenceNumber, long snapshotStartSequenceNumber, long snapshotEndSequenceNumber, String bucket, String password, DCPConnection connection)
public long vbucketUUID()
public long startSequenceNumber()
public long endSequenceNumber()
public long snapshotStartSequenceNumber()
public long snapshotEndSequenceNumber()
public DCPConnection connection()
Copyright © 2016 Couchbase, Inc.. All rights reserved.