Package org.apache.cassandra.service

Class LoadBroadcaster

java.lang.Object

org.apache.cassandra.service.LoadBroadcaster

All Implemented Interfaces:

IEndpointStateChangeSubscriber

public class LoadBroadcaster
extends Object
implements IEndpointStateChangeSubscriber

Field Summary

Fields

Modifier and Type	Field	Description
static final LoadBroadcaster	instance

Method Summary

Modifier and Type	Method	Description
Map<InetAddressAndPort,Double>	getLoadInfo()
void	onChange(InetAddressAndPort endpoint, ApplicationState state, VersionedValue value)
void	onJoin(InetAddressAndPort endpoint, EndpointState epState)	Use to inform interested parties about the change in the state for specified endpoint
void	onRemove(InetAddressAndPort endpoint)
void	startBroadcasting()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.cassandra.gms.IEndpointStateChangeSubscriber

beforeChange, onAlive, onDead, onRestart

Field Details

instance

public static final LoadBroadcaster instance

Method Details

onChange

public void onChange(InetAddressAndPort endpoint,
 ApplicationState state,
 VersionedValue value)

Specified by:

onChange in interface IEndpointStateChangeSubscriber

onJoin

public void onJoin(InetAddressAndPort 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.

onRemove

public void onRemove(InetAddressAndPort endpoint)

Specified by:

onRemove in interface IEndpointStateChangeSubscriber

getLoadInfo

public Map<InetAddressAndPort,Double> getLoadInfo()

startBroadcasting

public void startBroadcasting()