Uses of Interface
net.spy.memcached.MemcachedNode

Packages that use MemcachedNode

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.

Uses of MemcachedNode in net.spy.memcached

Classes in net.spy.memcached that implement MemcachedNode

Modifier and Type	Class	Description
class	MemcachedNodeROImpl

Classes in net.spy.memcached that implement interfaces with type arguments of type MemcachedNode

Modifier and Type	Class	Description
(package private) class	ArrayModNodeLocator.NodeIterator
(package private) class	KetamaIterator	Implements an Iterator which the KetamaNodeLoctaor may return to a client for iterating through alternate nodes for a given key.

Fields in net.spy.memcached declared as MemcachedNode

Modifier and Type	Field	Description
private MemcachedNode[]	ArrayModNodeLocator.nodes
private final MemcachedNode	MemcachedNodeROImpl.root

Fields in net.spy.memcached with type parameters of type MemcachedNode

Modifier and Type	Field	Description
protected final ConcurrentLinkedQueue<MemcachedNode>	MemcachedConnection.addedQueue	AddedQueue is used to track the QueueAttachments for which operations have recently been queued.
private Collection<MemcachedNode>	KetamaNodeLocator.allNodes
private final TreeMap<Long, MemcachedNode>	KetamaIterator.ketamaNodes
private TreeMap<Long, MemcachedNode>	KetamaNodeLocator.ketamaNodes
private Map<MemcachedNode, String>	KetamaNodeKeyFormatter.nodeKeys
protected final ConcurrentLinkedQueue<MemcachedNode>	MemcachedConnection.nodesToShutdown	Holds all nodes that are scheduled for shutdown.
private final SortedMap<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(SocketAddress sa, SocketChannel c, int bufSize)
MemcachedNode	ConnectionFactory.createMemcachedNode(SocketAddress sa, SocketChannel c, int bufSize)	Create a new memcached node.
MemcachedNode	DefaultConnectionFactory.createMemcachedNode(SocketAddress sa, SocketChannel c, int bufSize)
private MemcachedNode	MemcachedClient.findNode(SocketAddress sa)
private MemcachedNode	TapConnectionProvider.findNode(SocketAddress sa)
private MemcachedNode	KetamaIterator.getNodeForKey(long hash)
(package private) MemcachedNode	KetamaNodeLocator.getNodeForKey(long hash)
MemcachedNode	ArrayModNodeLocator.getPrimary(String k)
MemcachedNode	KetamaNodeLocator.getPrimary(String k)
MemcachedNode	NodeLocator.getPrimary(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 List<MemcachedNode>	MemcachedConnection.createConnections(Collection<InetSocketAddress> addrs)	Create connections for the given list of addresses.
Collection<MemcachedNode>	ArrayModNodeLocator.getAll()
Collection<MemcachedNode>	KetamaNodeLocator.getAll()
Collection<MemcachedNode>	NodeLocator.getAll()	Get all memcached nodes.
protected TreeMap<Long, MemcachedNode>	KetamaNodeLocator.getKetamaNodes()
Iterator<MemcachedNode>	ArrayModNodeLocator.getSequence(String k)
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.

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(SelectionKey sk, MemcachedNode node)	Finish the connect phase and potentially verify its liveness.
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(SelectionKey sk, MemcachedNode node)	A helper method for MemcachedConnection.handleIO(java.nio.channels.SelectionKey) to handle reads and writes if appropriate.
private Operation	MemcachedConnection.handleReadsWhenChannelEndOfStream(Operation currentOp, MemcachedNode node, 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 List<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, CountDownLatch latch)	Construct a new operation for delivery to the given node.
private void	MemcachedConnection.potentiallyCloseLeakingChannel(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 given MemcachedNode for reconnect.
private void	MemcachedConnection.readBufferAndLogMetrics(Operation currentOp, 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(Map<MemcachedNode, Operation> ops)	Enqueue the given list of operations on each handling node.
CountDownLatch	MemcachedClient.broadcastOp(BroadcastOpFactory of, Collection<MemcachedNode> nodes)
private CountDownLatch	MemcachedClient.broadcastOp(BroadcastOpFactory of, Collection<MemcachedNode> nodes, boolean checkShuttingDown)
CountDownLatch	MemcachedClientIF.broadcastOp(BroadcastOpFactory of, Collection<MemcachedNode> nodes)
private CountDownLatch	TapConnectionProvider.broadcastOp(BroadcastOpFactory of, Collection<MemcachedNode> nodes, boolean checkShuttingDown)
CountDownLatch	MemcachedConnection.broadcastOperation(BroadcastOpFactory of, Collection<MemcachedNode> nodes)	Broadcast an operation to a collection of nodes.
NodeLocator	ConnectionFactory.createLocator(List<MemcachedNode> nodes)	Create a NodeLocator instance for the given list of nodes.
NodeLocator	DefaultConnectionFactory.createLocator(List<MemcachedNode> nodes)
NodeLocator	KetamaConnectionFactory.createLocator(List<MemcachedNode> nodes)
protected void	KetamaNodeLocator.setKetamaNodes(List<MemcachedNode> nodes)	Setup the KetamaNodeLocator with the list of nodes it should use.
void	ArrayModNodeLocator.updateLocator(List<MemcachedNode> newNodes)
void	KetamaNodeLocator.updateLocator(List<MemcachedNode> nodes)
void	NodeLocator.updateLocator(List<MemcachedNode> nodes)	Update locator status.

Constructors in net.spy.memcached with parameters of type MemcachedNode

Modifier	Constructor	Description
private	ArrayModNodeLocator(MemcachedNode[] n, HashAlgorithm alg)
	MemcachedNodeROImpl(MemcachedNode n)

Constructor parameters in net.spy.memcached with type arguments of type MemcachedNode

Modifier	Constructor	Description
	ArrayModNodeLocator(List<MemcachedNode> n, HashAlgorithm alg)	Construct an ArraymodNodeLocator over the given array of nodes and using the given hash algorithm.
protected	KetamaIterator(String k, int t, TreeMap<Long, MemcachedNode> ketamaNodes, HashAlgorithm hashAlg)	Create a new KetamaIterator to be used by a client for an operation.
	KetamaNodeLocator(List<MemcachedNode> nodes, HashAlgorithm alg)	Create a new KetamaNodeLocator using specified nodes and the specifed hash algorithm.
	KetamaNodeLocator(List<MemcachedNode> nodes, HashAlgorithm alg, Map<InetSocketAddress, Integer> nodeWeights, KetamaNodeLocatorConfiguration configuration)	Create a new KetamaNodeLocator with specific nodes, hash, node key format, and weight
	KetamaNodeLocator(List<MemcachedNode> nodes, HashAlgorithm alg, KetamaNodeKeyFormatter.Format nodeKeyFormat, Map<InetSocketAddress, Integer> weights)	Create a new KetamaNodeLocator with specific nodes, hash, node key format, and weight
	KetamaNodeLocator(List<MemcachedNode> nodes, HashAlgorithm alg, KetamaNodeLocatorConfiguration conf)	Create a new KetamaNodeLocator using specified nodes and the specifed hash algorithm and configuration.
private	KetamaNodeLocator(TreeMap<Long, MemcachedNode> smn, Collection<MemcachedNode> an, HashAlgorithm alg, Map<InetSocketAddress, Integer> nodeWeights, KetamaNodeLocatorConfiguration conf)
private	KetamaNodeLocator(TreeMap<Long, MemcachedNode> smn, Collection<MemcachedNode> an, HashAlgorithm alg, Map<InetSocketAddress, 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 final 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

Modifier	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
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(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(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 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
final 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
Collection<MemcachedNode>	MultiKeyOperationImpl.getNotMyVbucketNodes()
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(Collection<MemcachedNode> nodes)
void	SingleKeyOperationImpl.setNotMyVbucketNodes(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 final 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

Modifier	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
String	DefaultKetamaNodeLocatorConfiguration.getKeyForNode(MemcachedNode node, int repetition)	Delegates to the KetamaNodeKeyFormatter
String	KetamaNodeLocatorConfiguration.getKeyForNode(MemcachedNode node, int repetition)	Returns a uniquely identifying key, suitable for hashing by the KetamaNodeLocator algorithm.