Package | Description |
---|---|
com.couchbase.client | |
com.couchbase.client.vbucket | |
net.spy.memcached |
Memcached client and transformation utils
|
net.spy.memcached.auth |
Auth Utilities.
|
net.spy.memcached.ops |
Fundamental protocol operation interfaces
|
net.spy.memcached.protocol |
Base classes for protocol abstractions.
|
net.spy.memcached.protocol.ascii |
Low-level operations for the memcached ascii protocol
|
net.spy.memcached.protocol.binary |
Low-level operations for the memcached binary protocol
|
net.spy.memcached.tapmessage | |
net.spy.memcached.util |
Cache Utilities.
|
Modifier and Type | Method and Description |
---|---|
java.util.Map<MemcachedNode,ObserveResponse> |
CouchbaseClient.observe(java.lang.String key,
long cas) |
java.util.Map<MemcachedNode,ObserveResponse> |
CouchbaseClientIF.observe(java.lang.String key,
long cas)
Observe a key with a associated CAS.
|
Modifier and Type | Method and Description |
---|---|
boolean |
TapConnectionProvider.isPrimaryForKey(MemcachedNode node,
java.lang.String key) |
protected void |
CouchbaseConnection.queueReconnect(MemcachedNode node)
Only queue for reconnect if the given node is still part of the cluster.
|
protected void |
CouchbaseMemcachedConnection.queueReconnect(MemcachedNode node)
Only queue for reconnect if the given node is still part of the cluster.
|
Modifier and Type | Method and Description |
---|---|
void |
CouchbaseConnection.addOperations(java.util.Map<MemcachedNode,Operation> ops) |
NodeLocator |
CouchbaseConnectionFactory.createLocator(java.util.List<MemcachedNode> nodes) |
Modifier and Type | Method and Description |
---|---|
MemcachedNode |
VBucketNodeLocator.getAlternative(java.lang.String k,
java.util.Collection<MemcachedNode> notMyVbucketNodes)
Method returns the node that is not contained in the specified collection
of the failed nodes.
|
MemcachedNode |
VBucketNodeLocator.getPrimary(java.lang.String k)
Get the primary location for the given key.
|
MemcachedNode |
VBucketNodeLocator.getReplica(java.lang.String key,
int index)
Return a replica node for the given key and replica index.
|
MemcachedNode |
VBucketNodeLocator.getServerByIndex(int k) |
Modifier and Type | Method and Description |
---|---|
java.util.Collection<MemcachedNode> |
VBucketNodeLocator.getAll()
Get all memcached nodes.
|
java.util.Iterator<MemcachedNode> |
VBucketNodeLocator.getSequence(java.lang.String k)
Get an iterator over the sequence of nodes that make up the backup
locations for a given key.
|
Modifier and Type | Method and Description |
---|---|
MemcachedNode |
VBucketNodeLocator.getAlternative(java.lang.String k,
java.util.Collection<MemcachedNode> notMyVbucketNodes)
Method returns the node that is not contained in the specified collection
of the failed nodes.
|
void |
VBucketNodeLocator.updateLocator(java.util.Collection<MemcachedNode> nodes,
Config newconf) |
void |
VBucketNodeLocator.updateLocator(java.util.List<MemcachedNode> nodes) |
Constructor and Description |
---|
VBucketNodeLocator(java.util.List<MemcachedNode> nodes,
Config jsonConfig)
Construct a VBucketNodeLocator over the given JSON configuration string.
|
Modifier and Type | Field and Description |
---|---|
protected java.util.concurrent.ConcurrentLinkedQueue<MemcachedNode> |
MemcachedConnection.addedQueue |
protected java.util.concurrent.ConcurrentLinkedQueue<MemcachedNode> |
MemcachedConnection.nodesToShutdown |
Modifier and Type | Method and Description |
---|---|
MemcachedNode |
BinaryConnectionFactory.createMemcachedNode(java.net.SocketAddress sa,
java.nio.channels.SocketChannel c,
int bufSize) |
MemcachedNode |
ConnectionFactory.createMemcachedNode(java.net.SocketAddress sa,
java.nio.channels.SocketChannel c,
int bufSize)
Create a new memcached node.
|
MemcachedNode |
DefaultConnectionFactory.createMemcachedNode(java.net.SocketAddress sa,
java.nio.channels.SocketChannel c,
int bufSize) |
MemcachedNode |
ArrayModNodeLocator.getPrimary(java.lang.String k) |
MemcachedNode |
KetamaNodeLocator.getPrimary(java.lang.String k) |
MemcachedNode |
NodeLocator.getPrimary(java.lang.String k)
Get the primary location for the given key.
|
Modifier and Type | Method and Description |
---|---|
protected java.util.List<MemcachedNode> |
MemcachedConnection.createConnections(java.util.Collection<java.net.InetSocketAddress> a) |
java.util.Collection<MemcachedNode> |
ArrayModNodeLocator.getAll() |
java.util.Collection<MemcachedNode> |
KetamaNodeLocator.getAll() |
java.util.Collection<MemcachedNode> |
NodeLocator.getAll()
Get all memcached nodes.
|
protected java.util.TreeMap<java.lang.Long,MemcachedNode> |
KetamaNodeLocator.getKetamaNodes() |
java.util.Iterator<MemcachedNode> |
ArrayModNodeLocator.getSequence(java.lang.String k) |
java.util.Iterator<MemcachedNode> |
KetamaNodeLocator.getSequence(java.lang.String k) |
java.util.Iterator<MemcachedNode> |
NodeLocator.getSequence(java.lang.String k)
Get an iterator over the sequence of nodes that make up the backup
locations for a given key.
|
Modifier and Type | Method and Description |
---|---|
protected void |
MemcachedConnection.addOperation(MemcachedNode node,
Operation o) |
void |
TapConnectionProvider.addTapAckOp(MemcachedNode node,
Operation op) |
void |
MemcachedConnection.insertOperation(MemcachedNode node,
Operation o) |
Operation |
BroadcastOpFactory.newOp(MemcachedNode n,
java.util.concurrent.CountDownLatch latch)
Construct a new operation for delivery to the given node.
|
protected void |
MemcachedConnection.queueReconnect(MemcachedNode qa) |
Modifier and Type | Method and Description |
---|---|
void |
MemcachedConnection.addOperations(java.util.Map<MemcachedNode,Operation> ops) |
java.util.concurrent.CountDownLatch |
MemcachedClient.broadcastOp(BroadcastOpFactory of,
java.util.Collection<MemcachedNode> nodes) |
java.util.concurrent.CountDownLatch |
MemcachedConnection.broadcastOperation(BroadcastOpFactory of,
java.util.Collection<MemcachedNode> nodes)
Broadcast an operation to a specific collection of nodes.
|
NodeLocator |
ConnectionFactory.createLocator(java.util.List<MemcachedNode> nodes)
Create a NodeLocator instance for the given list of nodes.
|
NodeLocator |
DefaultConnectionFactory.createLocator(java.util.List<MemcachedNode> nodes) |
NodeLocator |
KetamaConnectionFactory.createLocator(java.util.List<MemcachedNode> nodes) |
protected void |
KetamaNodeLocator.setKetamaNodes(java.util.List<MemcachedNode> nodes)
Setup the KetamaNodeLocator with the list of nodes it should use.
|
void |
ArrayModNodeLocator.updateLocator(java.util.List<MemcachedNode> newNodes) |
void |
KetamaNodeLocator.updateLocator(java.util.List<MemcachedNode> nodes) |
void |
NodeLocator.updateLocator(java.util.List<MemcachedNode> nodes)
Update locator status.
|
Constructor and Description |
---|
ArrayModNodeLocator(java.util.List<MemcachedNode> n,
HashAlgorithm alg)
Construct an ArraymodNodeLocator over the given array of nodes and using
the given hash algorithm.
|
KetamaNodeLocator(java.util.List<MemcachedNode> nodes,
HashAlgorithm alg)
Create a new KetamaNodeLocator using specified nodes and the specifed hash
algorithm.
|
KetamaNodeLocator(java.util.List<MemcachedNode> nodes,
HashAlgorithm alg,
KetamaNodeLocatorConfiguration conf)
Create a new KetamaNodeLocator using specified nodes and the specifed hash
algorithm and configuration.
|
Modifier and Type | Method and Description |
---|---|
void |
AuthThreadMonitor.authConnection(MemcachedConnection conn,
OperationFactory opFact,
AuthDescriptor authDescriptor,
MemcachedNode node)
Authenticate a new connection.
|
Constructor and Description |
---|
AuthThread(MemcachedConnection c,
OperationFactory o,
AuthDescriptor a,
MemcachedNode n) |
Modifier and Type | Method and Description |
---|---|
MemcachedNode |
Operation.getHandlingNode()
Get the node that should've been handling this operation.
|
Modifier and Type | Method and Description |
---|---|
java.util.Collection<MemcachedNode> |
VBucketAware.getNotMyVbucketNodes() |
Modifier and Type | Method and Description |
---|---|
void |
VBucketAware.addNotMyVbucketNode(MemcachedNode node) |
void |
TapOperation.Callback.gotAck(MemcachedNode node,
TapOpcode opcode,
int opaque) |
void |
ObserveOperation.Callback.gotData(java.lang.String key,
long cas,
MemcachedNode node,
ObserveResponse or)
Callback for each result from a observe.
|
void |
Operation.setHandlingNode(MemcachedNode to)
Set a reference to the node that will be/is handling this operation.
|
Modifier and Type | Method and Description |
---|---|
void |
VBucketAware.setNotMyVbucketNodes(java.util.Collection<MemcachedNode> nodes) |
Modifier and Type | Class and Description |
---|---|
class |
TCPMemcachedNodeImpl
Represents a node with the memcached cluster, along with buffering and
operation queues.
|
Modifier and Type | Field and Description |
---|---|
protected java.util.Collection<MemcachedNode> |
BaseOperationImpl.notMyVbucketNodes |
Modifier and Type | Method and Description |
---|---|
MemcachedNode |
BaseOperationImpl.getHandlingNode() |
Modifier and Type | Method and Description |
---|---|
void |
BaseOperationImpl.setHandlingNode(MemcachedNode to) |
Modifier and Type | Class and Description |
---|---|
class |
AsciiMemcachedNodeImpl
Memcached node for the ASCII protocol.
|
Modifier and Type | Class and Description |
---|---|
class |
BinaryMemcachedNodeImpl
Implementation of MemcachedNode for speakers of the binary protocol.
|
Modifier and Type | Method and Description |
---|---|
MemcachedNode |
TapAck.getNode() |
Constructor and Description |
---|
TapAck(TapConnectionProvider conn,
MemcachedNode node,
TapOpcode opcode,
int opaque,
OperationCallback cb) |
Modifier and Type | Field and Description |
---|---|
protected java.util.Map<MemcachedNode,java.lang.String> |
DefaultKetamaNodeLocatorConfiguration.socketAddresses |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
DefaultKetamaNodeLocatorConfiguration.getKeyForNode(MemcachedNode node,
int repetition)
Returns a uniquely identifying key, suitable for hashing by the
KetamaNodeLocator algorithm.
|
java.lang.String |
KetamaNodeLocatorConfiguration.getKeyForNode(MemcachedNode node,
int repetition)
Returns a uniquely identifying key, suitable for hashing by the
KetamaNodeLocator algorithm.
|
protected java.lang.String |
DefaultKetamaNodeLocatorConfiguration.getSocketAddressForNode(MemcachedNode node)
Returns the socket address of a given MemcachedNode.
|
Copyright © 2006-2009 Dustin Sallings, 2009-2014 Couchbase, Inc.