@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) |
StreamRequestRequest(short partition,
long vbucketUUID,
long startSequenceNumber,
long endSequenceNumber,
long snapshotStartSequenceNumber,
long snapshotEndSequenceNumber,
String bucket,
String password) |
StreamRequestRequest(short partition,
String bucket) |
Modifier and Type | Method and Description |
---|---|
long |
endSequenceNumber() |
long |
snapshotEndSequenceNumber() |
long |
snapshotStartSequenceNumber() |
long |
startSequenceNumber() |
long |
vbucketUUID() |
partition, partition
bucket, creationTime, incrementRetryCount, observable, password, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
bucket, incrementRetryCount, observable, password
creationTime
public StreamRequestRequest(short partition, String bucket)
public StreamRequestRequest(short partition, long vbucketUUID, long startSequenceNumber, long endSequenceNumber, long snapshotStartSequenceNumber, long snapshotEndSequenceNumber, String bucket)
Copyright © 2014 Couchbase, Inc.