com.basho.riak.client.core

Class DefaultNodeManager

java.lang.Object

com.basho.riak.client.core.DefaultNodeManager

All Implemented Interfaces:

NodeManager, NodeStateListener

public class DefaultNodeManager
extends Object
implements NodeManager, NodeStateListener

The default NodeManager used by RiakCluster if none is specified. This NodeManager round-robins through a list of RiakNodes and attempts to execute the operation passed to it. If a node reports that it is health checking it is removed from the list until it sends an update that it is again running. If the selected node cannot accept the operation because all connections are in use or it unable to make a new connection, the next node in the list is tried until either the operation is accepted or all nodes have been tried. If no nodes are able to accept the operation its setException() method is called with a NoNodesAvailableException.

Since:

2.0

Author:

Brian Roach

Constructor Summary

Constructors

Constructor and Description
DefaultNodeManager()

Method Summary

Modifier and Type	Method and Description
void	addNode(RiakNode newNode)
boolean	executeOnNode(FutureOperation operation, RiakNode previousNode)
void	init(List<RiakNode> nodes)
void	nodeStateChanged(RiakNode node, RiakNode.State state)
boolean	removeNode(RiakNode node)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultNodeManager

public DefaultNodeManager()

Method Detail

init

public void init(List<RiakNode> nodes)

Specified by:

init in interface NodeManager

executeOnNode

public boolean executeOnNode(FutureOperation operation,
                             RiakNode previousNode)

Specified by:

executeOnNode in interface NodeManager

nodeStateChanged

public void nodeStateChanged(RiakNode node,
                             RiakNode.State state)

Specified by:

nodeStateChanged in interface NodeStateListener

addNode

public void addNode(RiakNode newNode)

Specified by:

addNode in interface NodeManager

removeNode

public boolean removeNode(RiakNode node)

Specified by:

removeNode in interface NodeManager