Class KetamaIterator

java.lang.Object

net.spy.memcached.compat.SpyObject

net.spy.memcached.KetamaIterator

All Implemented Interfaces:

Iterator<MemcachedNode>

class KetamaIterator
extends SpyObject
implements Iterator<MemcachedNode>

Implements an Iterator which the KetamaNodeLoctaor may return to a client for iterating through alternate nodes for a given key.

Field Summary

Fields

Modifier and Type	Field	Description
private final HashAlgorithm	hashAlg
private long	hashVal
private final TreeMap<Long, MemcachedNode>	ketamaNodes
private final String	key
private int	numTries
private int	remainingTries

Constructor Summary

Constructors

Modifier	Constructor	Description
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.

Method Summary

Modifier and Type	Method	Description
private MemcachedNode	getNodeForKey(long hash)
boolean	hasNext()
MemcachedNode	next()
private void	nextHash()
void	remove()

Methods inherited from class SpyObject

getLogger

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface Iterator

forEachRemaining

Field Details

key

private final String key

hashVal

private long hashVal

remainingTries

private int remainingTries

numTries

private int numTries

hashAlg

private final HashAlgorithm hashAlg

ketamaNodes

private final TreeMap<Long, MemcachedNode> ketamaNodes

Constructor Details

KetamaIterator

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.

Parameters:

k - the key to iterate for

t - the number of tries until giving up

ketamaNodes - the continuum in the form of a TreeMap to be used when selecting a node

hashAlg - the hash algorithm to use when selecting within the continuumq

Method Details

nextHash

private void nextHash()

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<MemcachedNode>

next

public MemcachedNode next()

Specified by:

next in interface Iterator<MemcachedNode>

remove

public void remove()

Specified by:

remove in interface Iterator<MemcachedNode>

getNodeForKey

private MemcachedNode getNodeForKey(long hash)