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 ConcurrentLinkedQueue<MemcachedNode> |
MemcachedConnection.addedQueue
AddedQueue is used to track the QueueAttachments for which operations
have recently been queued.
|
protected ConcurrentLinkedQueue<MemcachedNode> |
MemcachedConnection.nodesToShutdown
Holds all nodes that are scheduled for shutdown.
|
Modifier and Type | Method and Description |
---|---|
MemcachedNode |
ConnectionFactory.createMemcachedNode(SocketAddress sa,
SocketChannel c,
int bufSize)
Create a new memcached node.
|
MemcachedNode |
DefaultConnectionFactory.createMemcachedNode(SocketAddress sa,
SocketChannel c,
int bufSize) |
MemcachedNode |
BinaryConnectionFactory.createMemcachedNode(SocketAddress sa,
SocketChannel c,
int bufSize) |
MemcachedNode |
KetamaNodeLocator.getPrimary(String k) |
MemcachedNode |
NodeLocator.getPrimary(String k)
Get the primary location for the given key.
|
MemcachedNode |
ArrayModNodeLocator.getPrimary(String k) |
Modifier and Type | Method and Description |
---|---|
protected List<MemcachedNode> |
MemcachedConnection.createConnections(Collection<InetSocketAddress> addrs)
Create connections for the given list of addresses.
|
Collection<MemcachedNode> |
KetamaNodeLocator.getAll() |
Collection<MemcachedNode> |
NodeLocator.getAll()
Get all memcached nodes.
|
Collection<MemcachedNode> |
ArrayModNodeLocator.getAll() |
protected TreeMap<Long,MemcachedNode> |
KetamaNodeLocator.getKetamaNodes() |
Iterator<MemcachedNode> |
KetamaNodeLocator.getSequence(String k) |
Iterator<MemcachedNode> |
NodeLocator.getSequence(String k)
Get an iterator over the sequence of nodes that make up the backup
locations for a given key.
|
Iterator<MemcachedNode> |
ArrayModNodeLocator.getSequence(String k) |
Modifier and Type | Method and Description |
---|---|
protected void |
MemcachedConnection.addOperation(MemcachedNode node,
Operation o)
Enqueue an operation on the given node.
|
void |
TapConnectionProvider.addTapAckOp(MemcachedNode node,
Operation op) |
void |
MemcachedConnection.insertOperation(MemcachedNode node,
Operation o)
Insert an operation on the given node to the beginning of the queue.
|
Operation |
BroadcastOpFactory.newOp(MemcachedNode n,
CountDownLatch latch)
Construct a new operation for delivery to the given node.
|
protected void |
MemcachedConnection.queueReconnect(MemcachedNode node)
Enqueue the given
MemcachedNode for reconnect. |
Modifier and Type | Method and Description |
---|---|
void |
MemcachedConnection.addOperations(Map<MemcachedNode,Operation> ops)
Enqueue the given list of operations on each handling node.
|
CountDownLatch |
MemcachedClient.broadcastOp(BroadcastOpFactory of,
Collection<MemcachedNode> nodes) |
CountDownLatch |
MemcachedClientIF.broadcastOp(BroadcastOpFactory of,
Collection<MemcachedNode> nodes) |
CountDownLatch |
MemcachedConnection.broadcastOperation(BroadcastOpFactory of,
Collection<MemcachedNode> nodes)
Broadcast an operation to a collection of nodes.
|
NodeLocator |
KetamaConnectionFactory.createLocator(List<MemcachedNode> nodes) |
NodeLocator |
ConnectionFactory.createLocator(List<MemcachedNode> nodes)
Create a NodeLocator instance for the given list of nodes.
|
NodeLocator |
DefaultConnectionFactory.createLocator(List<MemcachedNode> nodes) |
protected void |
KetamaNodeLocator.setKetamaNodes(List<MemcachedNode> nodes)
Setup the KetamaNodeLocator with the list of nodes it should use.
|
void |
KetamaNodeLocator.updateLocator(List<MemcachedNode> nodes) |
void |
NodeLocator.updateLocator(List<MemcachedNode> nodes)
Update locator status.
|
void |
ArrayModNodeLocator.updateLocator(List<MemcachedNode> newNodes) |
Constructor and Description |
---|
ArrayModNodeLocator(List<MemcachedNode> n,
HashAlgorithm alg)
Construct an ArraymodNodeLocator over the given array of nodes and using
the given hash algorithm.
|
KetamaNodeLocator(List<MemcachedNode> nodes,
HashAlgorithm alg)
Create a new KetamaNodeLocator using specified nodes and the specifed hash
algorithm.
|
KetamaNodeLocator(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 |
---|---|
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(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(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 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 Map<MemcachedNode,String> |
DefaultKetamaNodeLocatorConfiguration.socketAddresses |
Modifier and Type | Method and Description |
---|---|
String |
KetamaNodeLocatorConfiguration.getKeyForNode(MemcachedNode node,
int repetition)
Returns a uniquely identifying key, suitable for hashing by the
KetamaNodeLocator algorithm.
|
String |
DefaultKetamaNodeLocatorConfiguration.getKeyForNode(MemcachedNode node,
int repetition)
Returns a uniquely identifying key, suitable for hashing by the
KetamaNodeLocator algorithm.
|
protected String |
DefaultKetamaNodeLocatorConfiguration.getSocketAddressForNode(MemcachedNode node)
Returns the socket address of a given MemcachedNode.
|
Copyright © 2017. All rights reserved.