|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectjava.lang.Thread
net.spy.memcached.compat.SpyThread
net.spy.memcached.MemcachedConnection
com.couchbase.client.CouchbaseConnection
public class CouchbaseConnection
Maintains connections to each node in a cluster of Couchbase Nodes.
Nested Class Summary |
---|
Nested classes/interfaces inherited from class java.lang.Thread |
---|
java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler |
Field Summary | |
---|---|
protected boolean |
reconfiguring
|
Fields inherited from class net.spy.memcached.MemcachedConnection |
---|
addedQueue, failureMode, locator, nodesToShutdown, running, selector, shutDown |
Fields inherited from class java.lang.Thread |
---|
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY |
Constructor Summary | |
---|---|
CouchbaseConnection(int bufSize,
CouchbaseConnectionFactory f,
java.util.List<java.net.InetSocketAddress> a,
java.util.Collection<net.spy.memcached.ConnectionObserver> obs,
net.spy.memcached.FailureMode fm,
net.spy.memcached.OperationFactory opfactory)
|
Method Summary | |
---|---|
void |
addOperation(java.lang.String key,
net.spy.memcached.ops.Operation o)
Add an operation to the given connection. |
void |
addOperations(java.util.Map<net.spy.memcached.MemcachedNode,net.spy.memcached.ops.Operation> ops)
|
void |
reconfigure(Bucket bucket)
Call on a configuration update. |
void |
run()
Infinitely loop processing IO. |
Methods inherited from class net.spy.memcached.MemcachedConnection |
---|
addObserver, addOperation, broadcastOperation, broadcastOperation, checkState, createConnections, enqueueOperation, getLocator, handleIO, insertOperation, opSucceeded, opTimedOut, queueReconnect, removeObserver, shutdown, toString |
Methods inherited from class net.spy.memcached.compat.SpyThread |
---|
getLogger |
Methods inherited from class java.lang.Thread |
---|
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, yield |
Methods inherited from class java.lang.Object |
---|
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
---|
protected volatile boolean reconfiguring
Constructor Detail |
---|
public CouchbaseConnection(int bufSize, CouchbaseConnectionFactory f, java.util.List<java.net.InetSocketAddress> a, java.util.Collection<net.spy.memcached.ConnectionObserver> obs, net.spy.memcached.FailureMode fm, net.spy.memcached.OperationFactory opfactory) throws java.io.IOException
java.io.IOException
Method Detail |
---|
public void reconfigure(Bucket bucket)
Reconfigurable
reconfigure
in interface Reconfigurable
bucket
- updated vbucket configurationpublic void addOperation(java.lang.String key, net.spy.memcached.ops.Operation o)
addOperation
in class net.spy.memcached.MemcachedConnection
key
- the key the operation is operating upono
- the operationpublic void addOperations(java.util.Map<net.spy.memcached.MemcachedNode,net.spy.memcached.ops.Operation> ops)
addOperations
in class net.spy.memcached.MemcachedConnection
public void run()
run
in interface java.lang.Runnable
run
in class net.spy.memcached.MemcachedConnection
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |