com.couchbase.client.vbucket

Class VBucketNodeLocator

java.lang.Object

net.spy.memcached.compat.SpyObject

com.couchbase.client.vbucket.VBucketNodeLocator

All Implemented Interfaces:

NodeLocator

public class VBucketNodeLocator
extends SpyObject
implements NodeLocator

Implementation of the NodeLocator interface that contains vbucket hashing methods.

Constructor Summary

Constructors

Constructor and Description
VBucketNodeLocator(java.util.List<MemcachedNode> nodes, Config jsonConfig) Construct a VBucketNodeLocator over the given JSON configuration string.

Method Summary

Methods

Modifier and Type	Method and Description
java.util.Collection<MemcachedNode>	getAll() Get all memcached nodes.
MemcachedNode	getAlternative(java.lang.String k, java.util.Collection<MemcachedNode> notMyVbucketNodes) Method returns the node that is not contained in the specified collection of the failed nodes.
MemcachedNode	getPrimary(java.lang.String k) Get the primary location for the given key.
NodeLocator	getReadonlyCopy() Create a read-only copy of this NodeLocator.
java.util.Iterator<MemcachedNode>	getSequence(java.lang.String k) Get an iterator over the sequence of nodes that make up the backup locations for a given key.
MemcachedNode	getServerByIndex(int k)
int	getVBucketIndex(java.lang.String key) Returns a vbucket index for the given key.
void	updateLocator(java.util.Collection<MemcachedNode> nodes, Config newconf)
void	updateLocator(java.util.List<MemcachedNode> nodes) Update locator status.

Methods inherited from class net.spy.memcached.compat.SpyObject

getLogger

Methods inherited from class java.lang.Object

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

Constructor Detail

VBucketNodeLocator

public VBucketNodeLocator(java.util.List<MemcachedNode> nodes,
                  Config jsonConfig)

Construct a VBucketNodeLocator over the given JSON configuration string.

Parameters:

nodes -

jsonConfig -

Method Detail

getPrimary

public MemcachedNode getPrimary(java.lang.String k)

Get the primary location for the given key.

Specified by:

getPrimary in interface NodeLocator

Parameters:

k - the object key

Returns:

the QueueAttachment containing the primary storage for a key

getServerByIndex

public MemcachedNode getServerByIndex(int k)

getSequence

public java.util.Iterator<MemcachedNode> getSequence(java.lang.String k)

Get an iterator over the sequence of nodes that make up the backup locations for a given key.

Specified by:

getSequence in interface NodeLocator

Parameters:

k - the object key

Returns:

the sequence of backup nodes.

getAll

public java.util.Collection<MemcachedNode> getAll()

Get all memcached nodes. This is useful for broadcasting messages.

Specified by:

getAll in interface NodeLocator

getReadonlyCopy

public NodeLocator getReadonlyCopy()

Create a read-only copy of this NodeLocator.

Specified by:

getReadonlyCopy in interface NodeLocator

updateLocator

public void updateLocator(java.util.List<MemcachedNode> nodes)

Description copied from interface: NodeLocator

Update locator status.

Specified by:

updateLocator in interface NodeLocator

Parameters:

nodes - New locator nodes.

updateLocator

public void updateLocator(java.util.Collection<MemcachedNode> nodes,
                 Config newconf)

getVBucketIndex

public int getVBucketIndex(java.lang.String key)

Returns a vbucket index for the given key.

Parameters:

key - the key

Returns:

vbucket index

getAlternative

public MemcachedNode getAlternative(java.lang.String k,
                           java.util.Collection<MemcachedNode> notMyVbucketNodes)

Method returns the node that is not contained in the specified collection of the failed nodes.

Parameters:

k - the key

notMyVbucketNodes - a collection of the nodes are excluded

Returns:

The first MemcachedNode which meets requirements