com.xjeffrose.xio.client.loadbalancer

Class Distributor

java.lang.Object

com.xjeffrose.xio.client.loadbalancer.Distributor

All Implemented Interfaces:

Closeable, AutoCloseable

public class Distributor
extends Object
implements Closeable

Creates a new Distributor to perform load balancing

Constructor Summary

Constructors

Constructor and Description
Distributor(com.google.common.collect.ImmutableList<Node> pool, Strategy strategy, NodeHealthCheck nodeHealthCheck, XioTimer xioTimer)

Method Summary

Modifier and Type	Method and Description
void	close()
Node	getNodeById(UUID id) The node returned by UUID.
List<NodeStat>	getNodeStat()
Map<UUID,Node>	getOkNodes()
com.google.common.collect.ImmutableList<Node>	getPool()
Node	pick() Pick the next node.
Distributor	rebuild() Rebuild this distributor.
Distributor	rebuild(com.google.common.collect.ImmutableList<Node> list) Rebuild this distributor with a new vector.
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

Distributor

public Distributor(com.google.common.collect.ImmutableList<Node> pool,
                   Strategy strategy,
                   NodeHealthCheck nodeHealthCheck,
                   XioTimer xioTimer)

Method Detail

stop

public void stop()

getNodeById

public Node getNodeById(UUID id)

The node returned by UUID.

pick

public Node pick()

Pick the next node. This is the main load balancer.

rebuild

public Distributor rebuild()

Rebuild this distributor.

rebuild

public Distributor rebuild(com.google.common.collect.ImmutableList<Node> list)

Rebuild this distributor with a new vector.

getPool

public com.google.common.collect.ImmutableList<Node> getPool()

getNodeStat

public List<NodeStat> getNodeStat()

getOkNodes

public Map<UUID,Node> getOkNodes()

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException