Package | Description |
---|---|
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 | 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 |
ConnectionFactory.createMemcachedNode(java.net.SocketAddress sa,
java.nio.channels.SocketChannel c,
int bufSize)
Create a new memcached node.
|
MemcachedNode |
BinaryConnectionFactory.createMemcachedNode(java.net.SocketAddress sa,
java.nio.channels.SocketChannel c,
int bufSize) |
MemcachedNode |
DefaultConnectionFactory.createMemcachedNode(java.net.SocketAddress sa,
java.nio.channels.SocketChannel c,
int bufSize) |
MemcachedNode |
NodeLocator.getPrimary(java.lang.String k)
Get the primary location for the given key.
|
MemcachedNode |
KetamaNodeLocator.getPrimary(java.lang.String k) |
MemcachedNode |
ArrayModNodeLocator.getPrimary(java.lang.String k) |
Modifier and Type | Method and Description |
---|---|
protected java.util.List<MemcachedNode> |
MemcachedConnection.createConnections(java.util.Collection<java.net.InetSocketAddress> a) |
java.util.Collection<MemcachedNode> |
NodeLocator.getAll()
Get all memcached nodes.
|
java.util.Collection<MemcachedNode> |
KetamaNodeLocator.getAll() |
java.util.Collection<MemcachedNode> |
ArrayModNodeLocator.getAll() |
protected java.util.TreeMap<java.lang.Long,MemcachedNode> |
KetamaNodeLocator.getKetamaNodes() |
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.
|
java.util.Iterator<MemcachedNode> |
KetamaNodeLocator.getSequence(java.lang.String k) |
java.util.Iterator<MemcachedNode> |
ArrayModNodeLocator.getSequence(java.lang.String k) |
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 |
KetamaConnectionFactory.createLocator(java.util.List<MemcachedNode> nodes) |
NodeLocator |
DefaultConnectionFactory.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 |
NodeLocator.updateLocator(java.util.List<MemcachedNode> nodes)
Update locator status.
|
void |
KetamaNodeLocator.updateLocator(java.util.List<MemcachedNode> nodes) |
void |
ArrayModNodeLocator.updateLocator(java.util.List<MemcachedNode> newNodes) |
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-2013 Couchbase, Inc.