Package org.apache.cassandra.net

Class LatencySubscribers

java.lang.Object

org.apache.cassandra.net.LatencySubscribers

public class LatencySubscribers
extends java.lang.Object

Callback that DynamicEndpointSnitch listens to in order to update host scores. FIXME: rename/specialise, since only used by DES?

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	LatencySubscribers.Subscriber

Constructor Summary

Constructors

Constructor	Description
LatencySubscribers()

Method Summary

Modifier and Type	Method	Description
void	add(InetAddressAndPort address, long latency, java.util.concurrent.TimeUnit unit)
void	maybeAdd(RequestCallback cb, InetAddressAndPort address, long latency, java.util.concurrent.TimeUnit unit)	Track latency information for the dynamic snitch
void	subscribe(LatencySubscribers.Subscriber subscriber)

Methods inherited from class java.lang.Object

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

Constructor Detail

LatencySubscribers

public LatencySubscribers()

Method Detail

subscribe

public void subscribe(LatencySubscribers.Subscriber subscriber)

add

public void add(InetAddressAndPort address,
                long latency,
                java.util.concurrent.TimeUnit unit)

maybeAdd

public void maybeAdd(RequestCallback cb,
                     InetAddressAndPort address,
                     long latency,
                     java.util.concurrent.TimeUnit unit)

Track latency information for the dynamic snitch

Parameters:

cb - the callback associated with this message -- this lets us know if it's a message type we're interested in

address - the host that replied to the message