|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectnet.spy.memcached.compat.SpyObject
net.spy.memcached.MemcachedClient
com.couchbase.client.CouchbaseClient
public class CouchbaseClient
A client for Couchbase Server. This class acts as your main entry point while working with your Couchbase cluster (if you want to work with TAP, see the TapClient instead). If you are working with Couchbase Server 2.0, remember to set the appropriate view mode depending on your environment.
Field Summary | |
---|---|
static java.lang.String |
MODE_PREFIX
|
protected boolean |
reconfiguring
|
Fields inherited from class net.spy.memcached.MemcachedClient |
---|
authDescriptor, authMonitor, connFactory, mconn, operationTimeout, opFact, shuttingDown, tcService, transcoder |
Fields inherited from interface net.spy.memcached.MemcachedClientIF |
---|
MAX_KEY_LENGTH |
Constructor Summary | |
---|---|
CouchbaseClient(CouchbaseConnectionFactory cf)
Get a CouchbaseClient based on the settings from the given CouchbaseConnectionFactory. |
|
CouchbaseClient(java.util.List<java.net.URI> baseList,
java.lang.String bucketName,
java.lang.String pwd)
Get a CouchbaseClient based on the initial server list provided. |
|
CouchbaseClient(java.util.List<java.net.URI> baseList,
java.lang.String bucketName,
java.lang.String user,
java.lang.String pwd)
Get a CouchbaseClient based on the initial server list provided. |
Method Summary | ||
---|---|---|
net.spy.memcached.internal.OperationFuture<java.lang.Boolean> |
add(java.lang.String key,
int exp,
java.lang.Object value,
net.spy.memcached.PersistTo req)
Add a value with durability options. |
|
net.spy.memcached.internal.OperationFuture<java.lang.Boolean> |
add(java.lang.String key,
int exp,
java.lang.Object value,
net.spy.memcached.PersistTo req,
net.spy.memcached.ReplicateTo rep)
Add a value with durability options. |
|
net.spy.memcached.internal.OperationFuture<java.lang.Boolean> |
add(java.lang.String key,
int exp,
java.lang.Object value,
net.spy.memcached.ReplicateTo rep)
Add a value with durability options. |
|
void |
addOp(HttpOperation op)
Adds an operation to the queue where it waits to be sent to Couchbase. |
|
HttpFuture<java.lang.Boolean> |
asyncCreateDesignDoc(DesignDocument doc)
Store a design document in the cluster. |
|
HttpFuture<java.lang.Boolean> |
asyncCreateDesignDoc(java.lang.String name,
java.lang.String value)
Store a design document in the cluster. |
|
HttpFuture<java.lang.Boolean> |
asyncDeleteDesignDoc(java.lang.String name)
Delete a design document in the cluster. |
|
net.spy.memcached.internal.OperationFuture<net.spy.memcached.CASValue<java.lang.Object>> |
asyncGetAndLock(java.lang.String key,
int exp)
Get and lock the given key asynchronously and decode with the default transcoder. |
|
|
asyncGetAndLock(java.lang.String key,
int exp,
net.spy.memcached.transcoders.Transcoder<T> tc)
Gets and locks the given key asynchronously. |
|
HttpFuture<DesignDocument> |
asyncGetDesignDocument(java.lang.String designDocumentName)
Gets a future with a design document from the cluster. |
|
HttpFuture<SpatialView> |
asyncGetSpatialView(java.lang.String designDocumentName,
java.lang.String viewName)
Gets access to a spatial view contained in a design document from the cluster. |
|
HttpFuture<View> |
asyncGetView(java.lang.String designDocumentName,
java.lang.String viewName)
Gets access to a view contained in a design document from the cluster. |
|
HttpFuture<ViewResponse> |
asyncQuery(AbstractView view,
Query query)
|
|
net.spy.memcached.internal.OperationFuture<java.lang.Boolean> |
asyncUnlock(java.lang.String key,
long casId)
Unlock the given key asynchronously from the cache with the default transcoder. |
|
|
asyncUnlock(java.lang.String key,
long casId,
net.spy.memcached.transcoders.Transcoder<T> tc)
Unlock the given key asynchronously from the cache. |
|
net.spy.memcached.CASResponse |
cas(java.lang.String key,
long cas,
java.lang.Object value,
net.spy.memcached.PersistTo req)
Set a value with a CAS and durability options. |
|
net.spy.memcached.CASResponse |
cas(java.lang.String key,
long cas,
java.lang.Object value,
net.spy.memcached.PersistTo req,
net.spy.memcached.ReplicateTo rep)
Set a value with a CAS and durability options. |
|
net.spy.memcached.CASResponse |
cas(java.lang.String key,
long cas,
java.lang.Object value,
net.spy.memcached.ReplicateTo rep)
Set a value with a CAS and durability options. |
|
java.lang.Boolean |
createDesignDoc(DesignDocument doc)
Store a design document in the cluster. |
|
net.spy.memcached.internal.OperationFuture<java.lang.Boolean> |
delete(java.lang.String key,
net.spy.memcached.PersistTo req)
Delete a value with durability options for persistence. |
|
net.spy.memcached.internal.OperationFuture<java.lang.Boolean> |
delete(java.lang.String key,
net.spy.memcached.PersistTo req,
net.spy.memcached.ReplicateTo rep)
Delete a value with durability options. |
|
net.spy.memcached.internal.OperationFuture<java.lang.Boolean> |
delete(java.lang.String key,
net.spy.memcached.ReplicateTo req)
Delete a value with durability options for replication. |
|
java.lang.Boolean |
deleteDesignDoc(java.lang.String name)
Delete a design document in the cluster. |
|
net.spy.memcached.internal.OperationFuture<java.lang.Boolean> |
flush()
Flush all data from the bucket immediately. |
|
net.spy.memcached.internal.OperationFuture<java.lang.Boolean> |
flush(int delay)
Flush all caches from all servers with a delay of application. |
|
net.spy.memcached.CASValue<java.lang.Object> |
getAndLock(java.lang.String key,
int exp)
Get and lock with a single key and decode using the default transcoder. |
|
|
getAndLock(java.lang.String key,
int exp,
net.spy.memcached.transcoders.Transcoder<T> tc)
Getl with a single key. |
|
DesignDocument |
getDesignDocument(java.lang.String designDocumentName)
Returns a representation of a design document stored in the cluster. |
|
net.spy.memcached.internal.OperationFuture<java.util.Map<java.lang.String,java.lang.String>> |
getKeyStats(java.lang.String key)
|
|
int |
getNumVBuckets()
Gets the number of vBuckets that are contained in the cluster. |
|
SpatialView |
getSpatialView(java.lang.String designDocumentName,
java.lang.String viewName)
Gets access to a spatial view contained in a design document from the cluster. |
|
View |
getView(java.lang.String designDocumentName,
java.lang.String viewName)
Gets access to a view contained in a design document from the cluster. |
|
java.util.Map<net.spy.memcached.MemcachedNode,net.spy.memcached.ObserveResponse> |
observe(java.lang.String key,
long cas)
Observe a key with a associated CAS. |
|
void |
observePoll(java.lang.String key,
long cas,
net.spy.memcached.PersistTo persist,
net.spy.memcached.ReplicateTo replicate,
boolean isDelete)
Poll and observe a key with the given CAS and persist settings. |
|
Paginator |
paginatedQuery(View view,
Query query,
int docsPerPage)
A paginated query allows the user to get the results of a large query in small chunks allowing for better performance. |
|
ViewResponse |
query(AbstractView view,
Query query)
Queries a Couchbase view and returns the result. |
|
void |
reconfigure(Bucket bucket)
This method is called when there is a topology change in the cluster. |
|
net.spy.memcached.internal.OperationFuture<java.lang.Boolean> |
replace(java.lang.String key,
int exp,
java.lang.Object value,
net.spy.memcached.PersistTo req)
Replace a value with durability options. |
|
net.spy.memcached.internal.OperationFuture<java.lang.Boolean> |
replace(java.lang.String key,
int exp,
java.lang.Object value,
net.spy.memcached.PersistTo req,
net.spy.memcached.ReplicateTo rep)
Replace a value with durability options. |
|
net.spy.memcached.internal.OperationFuture<java.lang.Boolean> |
replace(java.lang.String key,
int exp,
java.lang.Object value,
net.spy.memcached.ReplicateTo rep)
Replace a value with durability options. |
|
net.spy.memcached.internal.OperationFuture<java.lang.Boolean> |
set(java.lang.String key,
int exp,
java.lang.Object value,
net.spy.memcached.PersistTo req)
Set a value with durability options. |
|
net.spy.memcached.internal.OperationFuture<java.lang.Boolean> |
set(java.lang.String key,
int exp,
java.lang.Object value,
net.spy.memcached.PersistTo req,
net.spy.memcached.ReplicateTo rep)
Set a value with durability options. |
|
net.spy.memcached.internal.OperationFuture<java.lang.Boolean> |
set(java.lang.String key,
int exp,
java.lang.Object value,
net.spy.memcached.ReplicateTo rep)
Set a value with durability options. |
|
boolean |
shutdown(long timeout,
java.util.concurrent.TimeUnit unit)
|
|
java.lang.Boolean |
unlock(java.lang.String key,
long casId)
Unlock the given key synchronously from the cache with the default transcoder. |
|
|
unlock(java.lang.String key,
long casId,
net.spy.memcached.transcoders.Transcoder<T> tc)
Unlock the given key synchronously from the cache. |
Methods inherited from class net.spy.memcached.MemcachedClient |
---|
add, add, addObserver, append, append, asyncCAS, asyncCAS, asyncCAS, asyncDecr, asyncDecr, asyncGet, asyncGet, asyncGetAndTouch, asyncGetAndTouch, asyncGetBulk, asyncGetBulk, asyncGetBulk, asyncGetBulk, asyncGetBulk, asyncGetBulk, asyncGetBulk, asyncGetBulk, asyncGets, asyncGets, asyncIncr, asyncIncr, broadcastOp, broadcastOp, cas, cas, cas, connectionEstablished, connectionLost, decr, decr, decr, decr, decr, decr, delete, delete, get, get, getAndTouch, getAndTouch, getAvailableServers, getBulk, getBulk, getBulk, getBulk, getBulk, getBulk, getNodeLocator, gets, gets, getStats, getStats, getTranscoder, getUnavailableServers, getVersions, incr, incr, incr, incr, incr, incr, listSaslMechanisms, prepend, prepend, removeObserver, replace, replace, set, set, shutdown, toString, touch, touch, waitForQueues |
Methods inherited from class net.spy.memcached.compat.SpyObject |
---|
getLogger |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface net.spy.memcached.MemcachedClientIF |
---|
add, add, addObserver, append, append, asyncCAS, asyncCAS, asyncDecr, asyncDecr, asyncGet, asyncGet, asyncGetAndTouch, asyncGetAndTouch, asyncGetBulk, asyncGetBulk, asyncGetBulk, asyncGetBulk, asyncGetBulk, asyncGetBulk, asyncGetBulk, asyncGetBulk, asyncGets, asyncGets, asyncIncr, asyncIncr, cas, cas, decr, decr, decr, decr, decr, decr, delete, get, get, getAndTouch, getAndTouch, getAvailableServers, getBulk, getBulk, getBulk, getBulk, getBulk, getBulk, getNodeLocator, gets, gets, getStats, getStats, getTranscoder, getUnavailableServers, getVersions, incr, incr, incr, incr, incr, incr, listSaslMechanisms, prepend, prepend, removeObserver, replace, replace, set, set, shutdown, touch, touch, waitForQueues |
Field Detail |
---|
public static final java.lang.String MODE_PREFIX
protected volatile boolean reconfiguring
Constructor Detail |
---|
public CouchbaseClient(java.util.List<java.net.URI> baseList, java.lang.String bucketName, java.lang.String pwd) throws java.io.IOException
baseList
- the URI list of one or more servers from the clusterbucketName
- the bucket name in the cluster you wish to usepwd
- the password for the bucket
java.io.IOException
- if connections could not be made
ConfigurationException
- if the configuration provided by the server
has issues or is not compatiblepublic CouchbaseClient(java.util.List<java.net.URI> baseList, java.lang.String bucketName, java.lang.String user, java.lang.String pwd) throws java.io.IOException
baseList
- the URI list of one or more servers from the clusterbucketName
- the bucket name in the cluster you wish to useuser
- the username for the bucketpwd
- the password for the bucket
java.io.IOException
- if connections could not be made
ConfigurationException
- if the configuration provided by the server
has issues or is not compatiblepublic CouchbaseClient(CouchbaseConnectionFactory cf) throws java.io.IOException
cf
- the ConnectionFactory to use to create connections
java.io.IOException
- if connections could not be made
ConfigurationException
- if the configuration provided by the server
has issues or is not compatibleMethod Detail |
---|
public void reconfigure(Bucket bucket)
reconfigure
in interface Reconfigurable
bucket
- updated vbucket configurationpublic HttpFuture<View> asyncGetView(java.lang.String designDocumentName, java.lang.String viewName)
designDocumentName
- the name of the design document.viewName
- the name of the view to get.
java.lang.InterruptedException
- if the operation is interrupted while in
flight
java.util.concurrent.ExecutionException
- if an error occurs during executionpublic HttpFuture<SpatialView> asyncGetSpatialView(java.lang.String designDocumentName, java.lang.String viewName)
designDocumentName
- the name of the design document.viewName
- the name of the spatial view to get.
java.lang.InterruptedException
- if the operation is interrupted while in
flight
java.util.concurrent.ExecutionException
- if an error occurs during executionpublic HttpFuture<DesignDocument> asyncGetDesignDocument(java.lang.String designDocumentName)
designDocumentName
- the name of the design document.
public View getView(java.lang.String designDocumentName, java.lang.String viewName)
designDocumentName
- the name of the design document.viewName
- the name of the view to get.
InvalidViewException
- if no design document or view was found.
java.util.concurrent.CancellationException
- if operation was canceled.public SpatialView getSpatialView(java.lang.String designDocumentName, java.lang.String viewName)
designDocumentName
- the name of the design document.viewName
- the name of the view to get.
InvalidViewException
- if no design document or view was found.
java.util.concurrent.CancellationException
- if operation was canceled.public DesignDocument getDesignDocument(java.lang.String designDocumentName)
designDocumentName
- the name of the design document.
InvalidViewException
- if no design document or view was found.
java.util.concurrent.CancellationException
- if operation was canceled.public java.lang.Boolean createDesignDoc(DesignDocument doc)
doc
- the design document to store.
java.util.concurrent.CancellationException
- if operation was canceled.public HttpFuture<java.lang.Boolean> asyncCreateDesignDoc(java.lang.String name, java.lang.String value) throws java.io.UnsupportedEncodingException
name
- the name of the design document.value
- the full design document definition as a string.
java.io.UnsupportedEncodingException
public HttpFuture<java.lang.Boolean> asyncCreateDesignDoc(DesignDocument doc) throws java.io.UnsupportedEncodingException
doc
- the design document to store.
java.io.UnsupportedEncodingException
public java.lang.Boolean deleteDesignDoc(java.lang.String name)
name
- the design document to delete.
java.util.concurrent.CancellationException
- if operation was canceled.public HttpFuture<java.lang.Boolean> asyncDeleteDesignDoc(java.lang.String name) throws java.io.UnsupportedEncodingException
name
- the design document to delete.
java.io.UnsupportedEncodingException
public HttpFuture<ViewResponse> asyncQuery(AbstractView view, Query query)
public ViewResponse query(AbstractView view, Query query)
view
- the view to run the query against.query
- the type of query to run against the view.
java.util.concurrent.CancellationException
- if operation was canceled.public Paginator paginatedQuery(View view, Query query, int docsPerPage)
view
- the view to query against.query
- the query for this request.docsPerPage
- the amount of documents per page.
public void addOp(HttpOperation op)
public <T> net.spy.memcached.internal.OperationFuture<net.spy.memcached.CASValue<T>> asyncGetAndLock(java.lang.String key, int exp, net.spy.memcached.transcoders.Transcoder<T> tc)
asyncGetAndLock
in interface CouchbaseClientIF
key
- the key to fetch and lockexp
- the amount of time the lock should be valid for in seconds.tc
- the transcoder to serialize and unserialize value
java.lang.IllegalStateException
- in the rare circumstance where queue is too
full to accept any more requestspublic net.spy.memcached.internal.OperationFuture<net.spy.memcached.CASValue<java.lang.Object>> asyncGetAndLock(java.lang.String key, int exp)
asyncGetAndLock
in interface CouchbaseClientIF
key
- the key to fetch and lockexp
- the amount of time the lock should be valid for in seconds.
java.lang.IllegalStateException
- in the rare circumstance where queue is too
full to accept any more requestspublic <T> net.spy.memcached.CASValue<T> getAndLock(java.lang.String key, int exp, net.spy.memcached.transcoders.Transcoder<T> tc)
getAndLock
in interface CouchbaseClientIF
key
- the key to get and lockexp
- the amount of time the lock should be valid for in seconds.tc
- the transcoder to serialize and unserialize value
net.spy.memcached.OperationTimeoutException
- if the global operation timeout is
exceeded
java.lang.IllegalStateException
- in the rare circumstance where queue is too
full to accept any more requests
java.util.concurrent.CancellationException
- if operation was canceledpublic net.spy.memcached.CASValue<java.lang.Object> getAndLock(java.lang.String key, int exp)
getAndLock
in interface CouchbaseClientIF
key
- the key to get and lockexp
- the amount of time the lock should be valid for in seconds.
net.spy.memcached.OperationTimeoutException
- if the global operation timeout is
exceeded
java.lang.IllegalStateException
- in the rare circumstance where queue is too
full to accept any more requestspublic <T> net.spy.memcached.internal.OperationFuture<java.lang.Boolean> asyncUnlock(java.lang.String key, long casId, net.spy.memcached.transcoders.Transcoder<T> tc)
asyncUnlock
in interface CouchbaseClientIF
key
- the key to unlockcasId
- the CAS identifiertc
- the transcoder to serialize and unserialize value
java.lang.IllegalStateException
- in the rare circumstance where queue is too
full to accept any more requestspublic net.spy.memcached.internal.OperationFuture<java.lang.Boolean> asyncUnlock(java.lang.String key, long casId)
asyncUnlock
in interface CouchbaseClientIF
key
- the key to unlockcasId
- the CAS identifier
java.lang.IllegalStateException
- in the rare circumstance where queue is too
full to accept any more requestspublic <T> java.lang.Boolean unlock(java.lang.String key, long casId, net.spy.memcached.transcoders.Transcoder<T> tc)
unlock
in interface CouchbaseClientIF
key
- the key to unlockcasId
- the CAS identifiertc
- the transcoder to serialize and unserialize value
java.lang.IllegalStateException
- in the rare circumstance where queue is too
full to accept any more requests
java.util.concurrent.CancellationException
- if operation was canceledpublic java.lang.Boolean unlock(java.lang.String key, long casId)
unlock
in interface CouchbaseClientIF
key
- the key to unlockcasId
- the CAS identifier
java.lang.IllegalStateException
- in the rare circumstance where queue is too
full to accept any more requestspublic net.spy.memcached.internal.OperationFuture<java.lang.Boolean> delete(java.lang.String key, net.spy.memcached.PersistTo req, net.spy.memcached.ReplicateTo rep)
delete
in interface CouchbaseClientIF
key
- the key to setreq
- the Persistence to Master valuerep
- the Persistence to Replicas
public net.spy.memcached.internal.OperationFuture<java.lang.Boolean> delete(java.lang.String key, net.spy.memcached.PersistTo req)
delete
in interface CouchbaseClientIF
key
- the key to setreq
- the persistence option requested
public net.spy.memcached.internal.OperationFuture<java.lang.Boolean> delete(java.lang.String key, net.spy.memcached.ReplicateTo req)
delete
in interface CouchbaseClientIF
key
- the key to setreq
- the replication option requested
public net.spy.memcached.internal.OperationFuture<java.lang.Boolean> set(java.lang.String key, int exp, java.lang.Object value, net.spy.memcached.PersistTo req, net.spy.memcached.ReplicateTo rep)
set
in interface CouchbaseClientIF
key
- the key to store.exp
- the expiry value to use.value
- the value of the key.req
- the amount of nodes the item should be persisted to before
returning.rep
- the amount of nodes the item should be replicated to before
returning.
public net.spy.memcached.internal.OperationFuture<java.lang.Boolean> set(java.lang.String key, int exp, java.lang.Object value, net.spy.memcached.PersistTo req)
set
in interface CouchbaseClientIF
key
- the key to store.exp
- the expiry value to use.value
- the value of the key.req
- the amount of nodes the item should be persisted to before
returning.
public net.spy.memcached.internal.OperationFuture<java.lang.Boolean> set(java.lang.String key, int exp, java.lang.Object value, net.spy.memcached.ReplicateTo rep)
set
in interface CouchbaseClientIF
key
- the key to store.exp
- the expiry value to use.value
- the value of the key.rep
- the amount of nodes the item should be replicated to before
returning.
public net.spy.memcached.internal.OperationFuture<java.lang.Boolean> add(java.lang.String key, int exp, java.lang.Object value, net.spy.memcached.PersistTo req, net.spy.memcached.ReplicateTo rep)
add
in interface CouchbaseClientIF
key
- the key to store.exp
- the expiry value to use.value
- the value of the key.req
- the amount of nodes the item should be persisted to before
returning.rep
- the amount of nodes the item should be replicated to before
returning.
public net.spy.memcached.internal.OperationFuture<java.lang.Boolean> add(java.lang.String key, int exp, java.lang.Object value, net.spy.memcached.PersistTo req)
add
in interface CouchbaseClientIF
key
- the key to store.exp
- the expiry value to use.value
- the value of the key.req
- the amount of nodes the item should be persisted to before
returning.
public net.spy.memcached.internal.OperationFuture<java.lang.Boolean> add(java.lang.String key, int exp, java.lang.Object value, net.spy.memcached.ReplicateTo rep)
add
in interface CouchbaseClientIF
key
- the key to store.exp
- the expiry value to use.value
- the value of the key.rep
- the amount of nodes the item should be replicated to before
returning.
public net.spy.memcached.internal.OperationFuture<java.lang.Boolean> replace(java.lang.String key, int exp, java.lang.Object value, net.spy.memcached.PersistTo req, net.spy.memcached.ReplicateTo rep)
replace
in interface CouchbaseClientIF
key
- the key to store.exp
- the expiry value to use.value
- the value of the key.req
- the amount of nodes the item should be persisted to before
returning.rep
- the amount of nodes the item should be replicated to before
returning.
public net.spy.memcached.internal.OperationFuture<java.lang.Boolean> replace(java.lang.String key, int exp, java.lang.Object value, net.spy.memcached.PersistTo req)
replace
in interface CouchbaseClientIF
key
- the key to store.exp
- the expiry value to use.value
- the value of the key.req
- the amount of nodes the item should be persisted to before
returning.
public net.spy.memcached.internal.OperationFuture<java.lang.Boolean> replace(java.lang.String key, int exp, java.lang.Object value, net.spy.memcached.ReplicateTo rep)
replace
in interface CouchbaseClientIF
key
- the key to store.exp
- the expiry value to use.value
- the value of the key.rep
- the amount of nodes the item should be replicated to before
returning.
public net.spy.memcached.CASResponse cas(java.lang.String key, long cas, java.lang.Object value, net.spy.memcached.PersistTo req, net.spy.memcached.ReplicateTo rep)
cas
in interface CouchbaseClientIF
key
- the key to store.cas
- the CAS value to use.value
- the value of the key.req
- the amount of nodes the item should be persisted to before
returning.rep
- the amount of nodes the item should be replicated to before
returning.
public net.spy.memcached.CASResponse cas(java.lang.String key, long cas, java.lang.Object value, net.spy.memcached.PersistTo req)
cas
in interface CouchbaseClientIF
key
- the key to store.cas
- the CAS value to use.value
- the value of the key.req
- the amount of nodes the item should be persisted to before
returning.
public net.spy.memcached.CASResponse cas(java.lang.String key, long cas, java.lang.Object value, net.spy.memcached.ReplicateTo rep)
cas
in interface CouchbaseClientIF
key
- the key to store.cas
- the CAS value to use.value
- the value of the key.rep
- the amount of nodes the item should be replicated to before
returning.
public java.util.Map<net.spy.memcached.MemcachedNode,net.spy.memcached.ObserveResponse> observe(java.lang.String key, long cas)
observe
in interface CouchbaseClientIF
key
- the key to observe.cas
- the CAS of the key (0 will ignore it).
java.lang.IllegalStateException
- in the rare circumstance where queue is too
full to accept any more requests.public int getNumVBuckets()
getNumVBuckets
in interface CouchbaseClientIF
public boolean shutdown(long timeout, java.util.concurrent.TimeUnit unit)
shutdown
in interface net.spy.memcached.MemcachedClientIF
shutdown
in class net.spy.memcached.MemcachedClient
public void observePoll(java.lang.String key, long cas, net.spy.memcached.PersistTo persist, net.spy.memcached.ReplicateTo replicate, boolean isDelete)
key
- the key to observe.cas
- the CAS value for the key.persist
- the persistence settings.replicate
- the replication settings.isDelete
- if the key is to be deleted.public net.spy.memcached.internal.OperationFuture<java.util.Map<java.lang.String,java.lang.String>> getKeyStats(java.lang.String key)
public net.spy.memcached.internal.OperationFuture<java.lang.Boolean> flush()
flush
in interface net.spy.memcached.MemcachedClientIF
flush
in class net.spy.memcached.MemcachedClient
public net.spy.memcached.internal.OperationFuture<java.lang.Boolean> flush(int delay)
flush
in interface net.spy.memcached.MemcachedClientIF
flush
in class net.spy.memcached.MemcachedClient
delay
- the period of time to delay, in seconds
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |