com.rabbitmq.perf

Class Stats

java.lang.Object

com.rabbitmq.perf.Stats

public abstract class Stats
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.concurrent.atomic.AtomicLong	confirmCountInterval
protected com.codahale.metrics.Histogram	confirmLatency
protected java.util.concurrent.atomic.AtomicLong	cumulativeLatencyInterval
protected java.util.concurrent.atomic.AtomicLong	cumulativeLatencyTotal
protected java.util.concurrent.atomic.AtomicLong	elapsedInterval
protected java.util.concurrent.atomic.AtomicLong	elapsedTotal
protected java.util.concurrent.atomic.AtomicReference<com.codahale.metrics.Histogram>	globalConfirmLatency
protected java.util.concurrent.atomic.AtomicReference<com.codahale.metrics.Histogram>	globalLatency
protected java.util.concurrent.atomic.AtomicLong	lastStatsTime
protected com.codahale.metrics.Histogram	latency
protected java.util.concurrent.atomic.AtomicLong	latencyCountInterval
protected java.util.concurrent.atomic.AtomicLong	latencyCountTotal
protected java.util.concurrent.atomic.AtomicLong	maxLatency
protected java.util.concurrent.atomic.AtomicLong	minLatency
protected java.util.concurrent.atomic.AtomicLong	nackCountInterval
protected static float	NANO_TO_SECOND
protected java.util.concurrent.atomic.AtomicLong	recvCountInterval
protected java.util.concurrent.atomic.AtomicLong	recvCountTotal
protected java.util.concurrent.atomic.AtomicLong	returnCountInterval
protected java.util.concurrent.atomic.AtomicLong	sendCountInterval
protected java.util.concurrent.atomic.AtomicLong	sendCountTotal
protected long	startTime
protected java.util.concurrent.atomic.AtomicLong	startTimeForGlobals

Constructor Summary

Constructors

Constructor and Description
Stats(java.time.Duration interval)
Stats(java.time.Duration interval, boolean useMs, io.micrometer.core.instrument.MeterRegistry registry, java.lang.String metricsPrefix)
Stats(java.time.Duration interval, boolean useMs, io.micrometer.core.instrument.MeterRegistry registry, java.lang.String metricsPrefix, PerformanceMetrics performanceMetrics)

Method Summary

Modifier and Type	Method and Description
protected void	confirmed(double rate)
void	handleConfirm(int numConfirms, long[] latencies)
void	handleNack(int numAcks)
void	handleRecv(long latency)
void	handleReturn()
void	handleSend()
protected void	nacked(double rate)
protected void	published(double rate)
protected void	received(double rate)
protected abstract void	report(long now)
protected void	returned(double rate)

Methods inherited from class java.lang.Object

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

Field Detail

NANO_TO_SECOND

protected static final float NANO_TO_SECOND

See Also:

Constant Field Values

startTime

protected final long startTime

startTimeForGlobals

protected final java.util.concurrent.atomic.AtomicLong startTimeForGlobals

lastStatsTime

protected java.util.concurrent.atomic.AtomicLong lastStatsTime

sendCountInterval

protected java.util.concurrent.atomic.AtomicLong sendCountInterval

returnCountInterval

protected java.util.concurrent.atomic.AtomicLong returnCountInterval

confirmCountInterval

protected java.util.concurrent.atomic.AtomicLong confirmCountInterval

nackCountInterval

protected java.util.concurrent.atomic.AtomicLong nackCountInterval

recvCountInterval

protected java.util.concurrent.atomic.AtomicLong recvCountInterval

sendCountTotal

protected java.util.concurrent.atomic.AtomicLong sendCountTotal

recvCountTotal

protected java.util.concurrent.atomic.AtomicLong recvCountTotal

latencyCountInterval

protected java.util.concurrent.atomic.AtomicLong latencyCountInterval

latencyCountTotal

protected java.util.concurrent.atomic.AtomicLong latencyCountTotal

minLatency

protected java.util.concurrent.atomic.AtomicLong minLatency

maxLatency

protected java.util.concurrent.atomic.AtomicLong maxLatency

cumulativeLatencyInterval

protected java.util.concurrent.atomic.AtomicLong cumulativeLatencyInterval

cumulativeLatencyTotal

protected java.util.concurrent.atomic.AtomicLong cumulativeLatencyTotal

elapsedInterval

protected java.util.concurrent.atomic.AtomicLong elapsedInterval

elapsedTotal

protected java.util.concurrent.atomic.AtomicLong elapsedTotal

latency

protected com.codahale.metrics.Histogram latency

confirmLatency

protected com.codahale.metrics.Histogram confirmLatency

globalLatency

protected final java.util.concurrent.atomic.AtomicReference<com.codahale.metrics.Histogram> globalLatency

globalConfirmLatency

protected final java.util.concurrent.atomic.AtomicReference<com.codahale.metrics.Histogram> globalConfirmLatency

Constructor Detail

Stats

public Stats(java.time.Duration interval)

Stats

public Stats(java.time.Duration interval,
             boolean useMs,
             io.micrometer.core.instrument.MeterRegistry registry,
             java.lang.String metricsPrefix)

Stats

public Stats(java.time.Duration interval,
             boolean useMs,
             io.micrometer.core.instrument.MeterRegistry registry,
             java.lang.String metricsPrefix,
             PerformanceMetrics performanceMetrics)

Method Detail

report

protected abstract void report(long now)

handleSend

public void handleSend()

handleReturn

public void handleReturn()

handleConfirm

public void handleConfirm(int numConfirms,
                          long[] latencies)

handleNack

public void handleNack(int numAcks)

handleRecv

public void handleRecv(long latency)

published

protected void published(double rate)

returned

protected void returned(double rate)

confirmed

protected void confirmed(double rate)

nacked

protected void nacked(double rate)

received

protected void received(double rate)