Package org.apache.cassandra.metrics

Class MessagingMetrics

java.lang.Object

org.apache.cassandra.metrics.MessagingMetrics

All Implemented Interfaces:

InboundMessageHandlers.GlobalMetricCallbacks

public class MessagingMetrics
extends Object
implements InboundMessageHandlers.GlobalMetricCallbacks

Metrics for messages

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MessagingMetrics.DCLatencyRecorder

Field Summary

Fields

Modifier and Type	Field	Description
final ConcurrentHashMap<String,MessagingMetrics.DCLatencyRecorder>	dcLatency
final EnumMap<Verb,com.codahale.metrics.Timer>	internalLatency

Constructor Summary

Constructors

Constructor	Description
MessagingMetrics()

Method Summary

Modifier and Type	Method	Description
Map<String,Integer>	getDroppedMessages()
MessagingMetrics.DCLatencyRecorder	internodeLatencyRecorder(InetAddressAndPort from)
void	recordDroppedMessage(Message<?> message, long timeElapsed, TimeUnit timeUnit)
void	recordDroppedMessage(Verb verb, long timeElapsed, TimeUnit timeUnit, boolean isCrossNode)
void	recordInternalLatency(Verb verb, long timeTaken, TimeUnit units)
void	recordInternodeDroppedMessage(Verb verb, long timeElapsed, TimeUnit timeUnit)
void	recordSelfDroppedMessage(Verb verb)
void	recordSelfDroppedMessage(Verb verb, long timeElapsed, TimeUnit timeUnit)
int	resetAndConsumeDroppedErrors(Consumer<String> messageConsumer)
void	resetDroppedMessages()
void	scheduleLogging()

Methods inherited from class java.lang.Object

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

Field Details

dcLatency

public final ConcurrentHashMap<String,MessagingMetrics.DCLatencyRecorder> dcLatency

internalLatency

public final EnumMap<Verb,com.codahale.metrics.Timer> internalLatency

Constructor Details

MessagingMetrics

public MessagingMetrics()

Method Details

internodeLatencyRecorder

public MessagingMetrics.DCLatencyRecorder internodeLatencyRecorder(InetAddressAndPort from)

Specified by:

internodeLatencyRecorder in interface InboundMessageHandlers.GlobalMetricCallbacks

recordInternalLatency

public void recordInternalLatency(Verb verb,
 long timeTaken,
 TimeUnit units)

Specified by:

recordInternalLatency in interface InboundMessageHandlers.GlobalMetricCallbacks

recordSelfDroppedMessage

public void recordSelfDroppedMessage(Verb verb)

recordSelfDroppedMessage

public void recordSelfDroppedMessage(Verb verb,
 long timeElapsed,
 TimeUnit timeUnit)

recordInternodeDroppedMessage

public void recordInternodeDroppedMessage(Verb verb,
 long timeElapsed,
 TimeUnit timeUnit)

Specified by:

recordInternodeDroppedMessage in interface InboundMessageHandlers.GlobalMetricCallbacks

recordDroppedMessage

public void recordDroppedMessage(Message<?> message,
 long timeElapsed,
 TimeUnit timeUnit)

recordDroppedMessage

public void recordDroppedMessage(Verb verb,
 long timeElapsed,
 TimeUnit timeUnit,
 boolean isCrossNode)

scheduleLogging

public void scheduleLogging()

getDroppedMessages

public Map<String,Integer> getDroppedMessages()

resetAndConsumeDroppedErrors

public int resetAndConsumeDroppedErrors(Consumer<String> messageConsumer)

resetDroppedMessages

public void resetDroppedMessages()