Uses of Interface
net.spy.memcached.MemcachedNode
-
Packages that use MemcachedNode Package Description net.spy.memcached Memcached client and transformation utilsnet.spy.memcached.auth Auth Utilities.net.spy.memcached.ops Fundamental protocol operation interfacesnet.spy.memcached.protocol Base classes for protocol abstractions.net.spy.memcached.protocol.ascii Low-level operations for the memcached ascii protocolnet.spy.memcached.protocol.binary Low-level operations for the memcached binary protocolnet.spy.memcached.tapmessage net.spy.memcached.util Cache Utilities. -
-
Uses of MemcachedNode in net.spy.memcached
Classes in net.spy.memcached that implement MemcachedNode Modifier and Type Class Description class
MemcachedNodeROImpl
Fields in net.spy.memcached declared as MemcachedNode Modifier and Type Field Description private MemcachedNode[]
ArrayModNodeLocator. nodes
private MemcachedNode
MemcachedNodeROImpl. root
Fields in net.spy.memcached with type parameters of type MemcachedNode Modifier and Type Field Description protected java.util.concurrent.ConcurrentLinkedQueue<MemcachedNode>
MemcachedConnection. addedQueue
AddedQueue is used to track the QueueAttachments for which operations have recently been queued.private java.util.Collection<MemcachedNode>
KetamaNodeLocator. allNodes
private java.util.TreeMap<java.lang.Long,MemcachedNode>
KetamaIterator. ketamaNodes
private java.util.TreeMap<java.lang.Long,MemcachedNode>
KetamaNodeLocator. ketamaNodes
private java.util.Map<MemcachedNode,java.lang.String>
KetamaNodeKeyFormatter. nodeKeys
protected java.util.concurrent.ConcurrentLinkedQueue<MemcachedNode>
MemcachedConnection. nodesToShutdown
Holds all nodes that are scheduled for shutdown.private java.util.SortedMap<java.lang.Long,MemcachedNode>
MemcachedConnection. reconnectQueue
reconnectQueue contains the attachments that need to be reconnected.Methods in net.spy.memcached that return MemcachedNode Modifier and Type Method 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)
private MemcachedNode
MemcachedClient. findNode(java.net.SocketAddress sa)
private MemcachedNode
TapConnectionProvider. findNode(java.net.SocketAddress sa)
private MemcachedNode
KetamaIterator. getNodeForKey(long hash)
(package private) MemcachedNode
KetamaNodeLocator. getNodeForKey(long hash)
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.MemcachedNode
ArrayModNodeLocator.NodeIterator. next()
MemcachedNode
KetamaIterator. next()
Methods in net.spy.memcached that return types with arguments of type MemcachedNode Modifier and Type Method Description protected java.util.List<MemcachedNode>
MemcachedConnection. createConnections(java.util.Collection<java.net.InetSocketAddress> addrs)
Create connections for the given list of addresses.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.Methods in net.spy.memcached with parameters of type MemcachedNode Modifier and Type Method Description protected void
MemcachedConnection. addOperation(MemcachedNode node, Operation o)
Enqueue an operation on the given node.void
TapConnectionProvider. addTapAckOp(MemcachedNode node, Operation op)
(package private) boolean
MemcachedConnection. belongsToCluster(MemcachedNode node)
Makes sure that the given node belongs to the current cluster.private void
MemcachedConnection. connected(MemcachedNode node)
Indicate a successful connect to the given node.private void
MemcachedConnection. finishConnect(java.nio.channels.SelectionKey sk, MemcachedNode node)
Finish the connect phase and potentially verify its liveness.java.lang.String
KetamaNodeKeyFormatter. getKeyForNode(MemcachedNode node, int repetition)
Returns a uniquely identifying key, suitable for hashing by the KetamaNodeLocator algorithm.private void
MemcachedConnection. handleReads(MemcachedNode node)
Handle pending reads for the given node.private void
MemcachedConnection. handleReadsAndWrites(java.nio.channels.SelectionKey sk, MemcachedNode node)
A helper method forMemcachedConnection.handleIO(java.nio.channels.SelectionKey)
to handle reads and writes if appropriate.private Operation
MemcachedConnection. handleReadsWhenChannelEndOfStream(Operation currentOp, MemcachedNode node, java.nio.ByteBuffer rbuf)
Deal with an operation where the channel reached the end of a stream.private void
MemcachedConnection. handleWrites(MemcachedNode node)
Handle pending writes for the given node.void
MemcachedConnection. insertOperation(MemcachedNode node, Operation o)
Insert an operation on the given node to the beginning of the queue.private java.util.List<java.lang.Long>
KetamaNodeLocator. ketamaNodePositionsAtIteration(MemcachedNode node, int iteration)
private void
MemcachedConnection. lostConnection(MemcachedNode node)
Indicate a lost connection to the given node.Operation
BroadcastOpFactory. newOp(MemcachedNode n, java.util.concurrent.CountDownLatch latch)
Construct a new operation for delivery to the given node.private void
MemcachedConnection. potentiallyCloseLeakingChannel(java.nio.channels.SocketChannel ch, MemcachedNode node)
Make sure channel connections are not leaked and properly close under faulty reconnect cirumstances.protected void
MemcachedConnection. queueReconnect(MemcachedNode node)
Enqueue the givenMemcachedNode
for reconnect.private void
MemcachedConnection. readBufferAndLogMetrics(Operation currentOp, java.nio.ByteBuffer rbuf, MemcachedNode node)
Read from the buffer and add metrics information.private void
TapClient. tapAck(TapConnectionProvider conn, MemcachedNode node, TapOpcode opcode, int opaque, OperationCallback cb)
Method parameters in net.spy.memcached with type arguments of type MemcachedNode Modifier and Type Method Description void
MemcachedConnection. addOperations(java.util.Map<MemcachedNode,Operation> ops)
Enqueue the given list of operations on each handling node.java.util.concurrent.CountDownLatch
MemcachedClient. broadcastOp(BroadcastOpFactory of, java.util.Collection<MemcachedNode> nodes)
private java.util.concurrent.CountDownLatch
MemcachedClient. broadcastOp(BroadcastOpFactory of, java.util.Collection<MemcachedNode> nodes, boolean checkShuttingDown)
java.util.concurrent.CountDownLatch
MemcachedClientIF. broadcastOp(BroadcastOpFactory of, java.util.Collection<MemcachedNode> nodes)
private java.util.concurrent.CountDownLatch
TapConnectionProvider. broadcastOp(BroadcastOpFactory of, java.util.Collection<MemcachedNode> nodes, boolean checkShuttingDown)
java.util.concurrent.CountDownLatch
MemcachedConnection. broadcastOperation(BroadcastOpFactory of, java.util.Collection<MemcachedNode> nodes)
Broadcast an operation to a 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.Constructors in net.spy.memcached with parameters of type MemcachedNode Constructor Description ArrayModNodeLocator(MemcachedNode[] n, HashAlgorithm alg)
MemcachedNodeROImpl(MemcachedNode n)
Constructor parameters in net.spy.memcached with type arguments of type MemcachedNode Constructor Description ArrayModNodeLocator(java.util.List<MemcachedNode> n, HashAlgorithm alg)
Construct an ArraymodNodeLocator over the given array of nodes and using the given hash algorithm.KetamaIterator(java.lang.String k, int t, java.util.TreeMap<java.lang.Long,MemcachedNode> ketamaNodes, HashAlgorithm hashAlg)
Create a new KetamaIterator to be used by a client for an operation.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, java.util.Map<java.net.InetSocketAddress,java.lang.Integer> nodeWeights, KetamaNodeLocatorConfiguration configuration)
Create a new KetamaNodeLocator with specific nodes, hash, node key format, and weightKetamaNodeLocator(java.util.List<MemcachedNode> nodes, HashAlgorithm alg, KetamaNodeKeyFormatter.Format nodeKeyFormat, java.util.Map<java.net.InetSocketAddress,java.lang.Integer> weights)
Create a new KetamaNodeLocator with specific nodes, hash, node key format, and weightKetamaNodeLocator(java.util.List<MemcachedNode> nodes, HashAlgorithm alg, KetamaNodeLocatorConfiguration conf)
Create a new KetamaNodeLocator using specified nodes and the specifed hash algorithm and configuration.KetamaNodeLocator(java.util.TreeMap<java.lang.Long,MemcachedNode> smn, java.util.Collection<MemcachedNode> an, HashAlgorithm alg, java.util.Map<java.net.InetSocketAddress,java.lang.Integer> nodeWeights, KetamaNodeLocatorConfiguration conf)
KetamaNodeLocator(java.util.TreeMap<java.lang.Long,MemcachedNode> smn, java.util.Collection<MemcachedNode> an, HashAlgorithm alg, java.util.Map<java.net.InetSocketAddress,java.lang.Integer> nodeWeights, KetamaNodeLocatorConfiguration conf)
-
Uses of MemcachedNode in net.spy.memcached.auth
Fields in net.spy.memcached.auth declared as MemcachedNode Modifier and Type Field Description private MemcachedNode
AuthThread. node
Methods in net.spy.memcached.auth with parameters of type MemcachedNode Modifier and Type Method Description void
AuthThreadMonitor. authConnection(MemcachedConnection conn, OperationFactory opFact, AuthDescriptor authDescriptor, MemcachedNode node)
Authenticate a new connection.private void
AuthThreadMonitor. interruptOldAuth(MemcachedNode nodeToStop)
Constructors in net.spy.memcached.auth with parameters of type MemcachedNode Constructor Description AuthThread(MemcachedConnection c, OperationFactory o, AuthDescriptor a, MemcachedNode n)
-
Uses of MemcachedNode in net.spy.memcached.ops
Methods in net.spy.memcached.ops that return MemcachedNode Modifier and Type Method Description MemcachedNode
Operation. getHandlingNode()
Get the node that should've been handling this operation.Methods in net.spy.memcached.ops that return types with arguments of type MemcachedNode Modifier and Type Method Description java.util.Collection<MemcachedNode>
VBucketAware. getNotMyVbucketNodes()
Methods in net.spy.memcached.ops with parameters of type MemcachedNode Modifier and Type Method 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.Method parameters in net.spy.memcached.ops with type arguments of type MemcachedNode Modifier and Type Method Description void
VBucketAware. setNotMyVbucketNodes(java.util.Collection<MemcachedNode> nodes)
-
Uses of MemcachedNode in net.spy.memcached.protocol
Classes in net.spy.memcached.protocol that implement MemcachedNode Modifier and Type Class Description class
TCPMemcachedNodeImpl
Represents a node with the memcached cluster, along with buffering and operation queues.Fields in net.spy.memcached.protocol declared as MemcachedNode Modifier and Type Field Description private MemcachedNode
BaseOperationImpl. handlingNode
Fields in net.spy.memcached.protocol with type parameters of type MemcachedNode Modifier and Type Field Description protected java.util.Collection<MemcachedNode>
BaseOperationImpl. notMyVbucketNodes
Methods in net.spy.memcached.protocol that return MemcachedNode Modifier and Type Method Description MemcachedNode
BaseOperationImpl. getHandlingNode()
Methods in net.spy.memcached.protocol with parameters of type MemcachedNode Modifier and Type Method Description void
BaseOperationImpl. setHandlingNode(MemcachedNode to)
-
Uses of MemcachedNode in net.spy.memcached.protocol.ascii
Classes in net.spy.memcached.protocol.ascii that implement MemcachedNode Modifier and Type Class Description class
AsciiMemcachedNodeImpl
Memcached node for the ASCII protocol. -
Uses of MemcachedNode in net.spy.memcached.protocol.binary
Classes in net.spy.memcached.protocol.binary that implement MemcachedNode Modifier and Type Class Description class
BinaryMemcachedNodeImpl
Implementation of MemcachedNode for speakers of the binary protocol.Methods in net.spy.memcached.protocol.binary that return types with arguments of type MemcachedNode Modifier and Type Method Description java.util.Collection<MemcachedNode>
MultiKeyOperationImpl. getNotMyVbucketNodes()
java.util.Collection<MemcachedNode>
SingleKeyOperationImpl. getNotMyVbucketNodes()
Methods in net.spy.memcached.protocol.binary with parameters of type MemcachedNode Modifier and Type Method Description void
MultiKeyOperationImpl. addNotMyVbucketNode(MemcachedNode node)
void
SingleKeyOperationImpl. addNotMyVbucketNode(MemcachedNode node)
Method parameters in net.spy.memcached.protocol.binary with type arguments of type MemcachedNode Modifier and Type Method Description void
MultiKeyOperationImpl. setNotMyVbucketNodes(java.util.Collection<MemcachedNode> nodes)
void
SingleKeyOperationImpl. setNotMyVbucketNodes(java.util.Collection<MemcachedNode> nodes)
-
Uses of MemcachedNode in net.spy.memcached.tapmessage
Fields in net.spy.memcached.tapmessage declared as MemcachedNode Modifier and Type Field Description private MemcachedNode
TapAck. node
Methods in net.spy.memcached.tapmessage that return MemcachedNode Modifier and Type Method Description MemcachedNode
TapAck. getNode()
Constructors in net.spy.memcached.tapmessage with parameters of type MemcachedNode Constructor Description TapAck(TapConnectionProvider conn, MemcachedNode node, TapOpcode opcode, int opaque, OperationCallback cb)
-
Uses of MemcachedNode in net.spy.memcached.util
Methods in net.spy.memcached.util with parameters of type MemcachedNode Modifier and Type Method Description java.lang.String
DefaultKetamaNodeLocatorConfiguration. getKeyForNode(MemcachedNode node, int repetition)
Delegates to the KetamaNodeKeyFormatterjava.lang.String
KetamaNodeLocatorConfiguration. getKeyForNode(MemcachedNode node, int repetition)
Returns a uniquely identifying key, suitable for hashing by the KetamaNodeLocator algorithm.
-