Package org.apache.cassandra.service
Class LoadBroadcaster
- java.lang.Object
-
- org.apache.cassandra.service.LoadBroadcaster
-
- All Implemented Interfaces:
IEndpointStateChangeSubscriber
public class LoadBroadcaster extends java.lang.Object implements IEndpointStateChangeSubscriber
-
-
Field Summary
Fields Modifier and Type Field Description static LoadBroadcasterinstance
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.Map<InetAddressAndPort,java.lang.Double>getLoadInfo()voidonChange(InetAddressAndPort endpoint, ApplicationState state, VersionedValue value)voidonJoin(InetAddressAndPort endpoint, EndpointState epState)Use to inform interested parties about the change in the state for specified endpointvoidonRemove(InetAddressAndPort endpoint)voidstartBroadcasting()-
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 Detail
-
instance
public static final LoadBroadcaster instance
-
-
Method Detail
-
onChange
public void onChange(InetAddressAndPort endpoint, ApplicationState state, VersionedValue value)
- Specified by:
onChangein interfaceIEndpointStateChangeSubscriber
-
onJoin
public void onJoin(InetAddressAndPort endpoint, EndpointState epState)
Description copied from interface:IEndpointStateChangeSubscriberUse to inform interested parties about the change in the state for specified endpoint- Specified by:
onJoinin interfaceIEndpointStateChangeSubscriber- 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:
onRemovein interfaceIEndpointStateChangeSubscriber
-
getLoadInfo
public java.util.Map<InetAddressAndPort,java.lang.Double> getLoadInfo()
-
startBroadcasting
public void startBroadcasting()
-
-