org.apache.cassandra.service
Class StorageLoadBalancer

java.lang.Object
  org.apache.cassandra.service.StorageLoadBalancer

All Implemented Interfaces:

IEndpointStateChangeSubscriber

public class StorageLoadBalancer
extends java.lang.Object
implements IEndpointStateChangeSubscriber

Field Summary

static StorageLoadBalancer

instance

Method Summary

java.util.Map<java.net.InetAddress,java.lang.Double>	getLoadInfo()
void	onAlive(java.net.InetAddress endpoint, EndpointState state)
void	onChange(java.net.InetAddress endpoint, ApplicationState state, VersionedValue value)
void	onDead(java.net.InetAddress endpoint, EndpointState state)
void	onJoin(java.net.InetAddress endpoint, EndpointState epState) Use to inform interested parties about the change in the state for specified endpoint
void	onRemove(java.net.InetAddress endpoint)
void	startBroadcasting()
void	waitForLoadInfo() Wait for at least BROADCAST_INTERVAL ms, to give all nodes enough time to report in.

Methods inherited from class java.lang.Object

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

Field Detail

instance

public static final StorageLoadBalancer instance

Method Detail

onChange

public void onChange(java.net.InetAddress endpoint,
                     ApplicationState state,
                     VersionedValue value)

Specified by:

onChange in interface IEndpointStateChangeSubscriber

onJoin

public void onJoin(java.net.InetAddress endpoint,
                   EndpointState epState)

Description copied from interface: IEndpointStateChangeSubscriber

Use to inform interested parties about the change in the state for specified endpoint

Specified by:

onJoin in interface IEndpointStateChangeSubscriber

Parameters:

endpoint - endpoint for which the state change occurred.

epState - state that actually changed for the above endpoint.

onAlive

public void onAlive(java.net.InetAddress endpoint,
                    EndpointState state)

Specified by:

onAlive in interface IEndpointStateChangeSubscriber

onDead

public void onDead(java.net.InetAddress endpoint,
                   EndpointState state)

Specified by:

onDead in interface IEndpointStateChangeSubscriber

onRemove

public void onRemove(java.net.InetAddress endpoint)

Specified by:

onRemove in interface IEndpointStateChangeSubscriber

getLoadInfo

public java.util.Map<java.net.InetAddress,java.lang.Double> getLoadInfo()

startBroadcasting

public void startBroadcasting()

waitForLoadInfo

public void waitForLoadInfo()

Wait for at least BROADCAST_INTERVAL ms, to give all nodes enough time to report in.