@InterfaceStability.Experimental @InterfaceAudience.Private public abstract class AbstractDCPRequest extends AbstractCouchbaseRequest implements DCPRequest
Default implementation of DCPRequest
.
Modifier and Type | Field and Description |
---|---|
protected static short |
DEFAULT_PARTITION |
Constructor and Description |
---|
AbstractDCPRequest(String bucket,
String password)
Creates a new
AbstractDCPRequest . |
AbstractDCPRequest(String bucket,
String password,
Subject<CouchbaseResponse,CouchbaseResponse> observable) |
Modifier and Type | Method and Description |
---|---|
short |
partition()
The partition (vBucket) to use for this request.
|
DCPRequest |
partition(short partition)
Set the partition ID.
|
String |
toString() |
bucket, creationTime, incrementRetryCount, observable, password
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
bucket, incrementRetryCount, observable, password
creationTime
public AbstractDCPRequest(String bucket, String password)
Creates a new AbstractDCPRequest
.
bucket
- the bucket of the document.password
- the optional password of the bucket.public AbstractDCPRequest(String bucket, String password, Subject<CouchbaseResponse,CouchbaseResponse> observable)
public short partition()
DCPRequest
The partition (vBucket) to use for this request.
partition
in interface DCPRequest
public DCPRequest partition(short partition)
DCPRequest
Set the partition ID.
partition
in interface DCPRequest
partition
- the id of the partition.DCPRequest
for proper chaining.public String toString()
toString
in class AbstractCouchbaseRequest
Copyright © 2014 Couchbase, Inc.