Uses of Interface
net.spy.memcached.MemcachedNode
Packages that use MemcachedNode
Package
Description
Memcached client and transformation utils
Auth Utilities.
Fundamental protocol operation interfaces
Base classes for protocol abstractions.
Low-level operations for the memcached ascii protocol
Low-level operations for the memcached binary protocol
Cache Utilities.
-
Uses of MemcachedNode in net.spy.memcached
Classes in net.spy.memcached that implement MemcachedNodeFields in net.spy.memcached declared as MemcachedNodeModifier and TypeFieldDescriptionprivate MemcachedNode[]
ArrayModNodeLocator.nodes
private final MemcachedNode
MemcachedNodeROImpl.root
Fields in net.spy.memcached with type parameters of type MemcachedNodeModifier and TypeFieldDescriptionprotected 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 MemcachedNodeModifier and TypeMethodDescriptionBinaryConnectionFactory.createMemcachedNode
(SocketAddress sa, SocketChannel c, int bufSize) ConnectionFactory.createMemcachedNode
(SocketAddress sa, SocketChannel c, int bufSize) Create a new memcached node.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) ArrayModNodeLocator.getPrimary
(String k) KetamaNodeLocator.getPrimary
(String k) NodeLocator.getPrimary
(String k) Get the primary location for the given key.ArrayModNodeLocator.NodeIterator.next()
KetamaIterator.next()
Methods in net.spy.memcached that return types with arguments of type MemcachedNodeModifier and TypeMethodDescriptionprotected List
<MemcachedNode> MemcachedConnection.createConnections
(Collection<InetSocketAddress> addrs) Create connections for the given list of addresses.ArrayModNodeLocator.getAll()
KetamaNodeLocator.getAll()
NodeLocator.getAll()
Get all memcached nodes.protected TreeMap
<Long, MemcachedNode> KetamaNodeLocator.getKetamaNodes()
ArrayModNodeLocator.getSequence
(String k) KetamaNodeLocator.getSequence
(String k) 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 MemcachedNodeModifier and TypeMethodDescriptionprotected 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.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 forMemcachedConnection.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.KetamaNodeLocator.ketamaNodePositionsAtIteration
(MemcachedNode node, int iteration) private void
MemcachedConnection.lostConnection
(MemcachedNode node) Indicate a lost connection to the given node.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 givenMemcachedNode
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 MemcachedNodeModifier and TypeMethodDescriptionvoid
MemcachedConnection.addOperations
(Map<MemcachedNode, Operation> ops) Enqueue the given list of operations on each handling node.MemcachedClient.broadcastOp
(BroadcastOpFactory of, Collection<MemcachedNode> nodes) private CountDownLatch
MemcachedClient.broadcastOp
(BroadcastOpFactory of, Collection<MemcachedNode> nodes, boolean checkShuttingDown) MemcachedClientIF.broadcastOp
(BroadcastOpFactory of, Collection<MemcachedNode> nodes) private CountDownLatch
TapConnectionProvider.broadcastOp
(BroadcastOpFactory of, Collection<MemcachedNode> nodes, boolean checkShuttingDown) MemcachedConnection.broadcastOperation
(BroadcastOpFactory of, Collection<MemcachedNode> nodes) Broadcast an operation to a collection of nodes.ConnectionFactory.createLocator
(List<MemcachedNode> nodes) Create a NodeLocator instance for the given list of nodes.DefaultConnectionFactory.createLocator
(List<MemcachedNode> nodes) 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 MemcachedNodeConstructor parameters in net.spy.memcached with type arguments of type MemcachedNodeModifierConstructorDescriptionConstruct 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 weightKetamaNodeLocator
(List<MemcachedNode> nodes, HashAlgorithm alg, KetamaNodeKeyFormatter.Format nodeKeyFormat, Map<InetSocketAddress, Integer> weights) Create a new KetamaNodeLocator with specific nodes, hash, node key format, and weightKetamaNodeLocator
(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 MemcachedNodeMethods in net.spy.memcached.auth with parameters of type MemcachedNodeModifier and TypeMethodDescriptionvoid
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 MemcachedNodeModifierConstructorDescription -
Uses of MemcachedNode in net.spy.memcached.ops
Methods in net.spy.memcached.ops that return MemcachedNodeModifier and TypeMethodDescriptionOperation.getHandlingNode()
Get the node that should've been handling this operation.Methods in net.spy.memcached.ops that return types with arguments of type MemcachedNodeMethods in net.spy.memcached.ops with parameters of type MemcachedNodeModifier and TypeMethodDescriptionvoid
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 MemcachedNodeModifier and TypeMethodDescriptionvoid
VBucketAware.setNotMyVbucketNodes
(Collection<MemcachedNode> nodes) -
Uses of MemcachedNode in net.spy.memcached.protocol
Classes in net.spy.memcached.protocol that implement MemcachedNodeModifier and TypeClassDescriptionclass
Represents a node with the memcached cluster, along with buffering and operation queues.Fields in net.spy.memcached.protocol declared as MemcachedNodeFields in net.spy.memcached.protocol with type parameters of type MemcachedNodeModifier and TypeFieldDescriptionprotected Collection
<MemcachedNode> BaseOperationImpl.notMyVbucketNodes
Methods in net.spy.memcached.protocol that return MemcachedNodeMethods in net.spy.memcached.protocol with parameters of type MemcachedNode -
Uses of MemcachedNode in net.spy.memcached.protocol.ascii
Classes in net.spy.memcached.protocol.ascii that implement MemcachedNodeModifier and TypeClassDescriptionfinal class
Memcached node for the ASCII protocol. -
Uses of MemcachedNode in net.spy.memcached.protocol.binary
Classes in net.spy.memcached.protocol.binary that implement MemcachedNodeModifier and TypeClassDescriptionclass
Implementation of MemcachedNode for speakers of the binary protocol.Methods in net.spy.memcached.protocol.binary that return types with arguments of type MemcachedNodeModifier and TypeMethodDescriptionMultiKeyOperationImpl.getNotMyVbucketNodes()
SingleKeyOperationImpl.getNotMyVbucketNodes()
Methods in net.spy.memcached.protocol.binary with parameters of type MemcachedNodeModifier and TypeMethodDescriptionvoid
MultiKeyOperationImpl.addNotMyVbucketNode
(MemcachedNode node) void
SingleKeyOperationImpl.addNotMyVbucketNode
(MemcachedNode node) Method parameters in net.spy.memcached.protocol.binary with type arguments of type MemcachedNodeModifier and TypeMethodDescriptionvoid
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 MemcachedNodeMethods in net.spy.memcached.tapmessage that return MemcachedNodeConstructors in net.spy.memcached.tapmessage with parameters of type MemcachedNodeModifierConstructorDescriptionTapAck
(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 MemcachedNodeModifier and TypeMethodDescriptionDefaultKetamaNodeLocatorConfiguration.getKeyForNode
(MemcachedNode node, int repetition) Delegates to the KetamaNodeKeyFormatterKetamaNodeLocatorConfiguration.getKeyForNode
(MemcachedNode node, int repetition) Returns a uniquely identifying key, suitable for hashing by the KetamaNodeLocator algorithm.