Package org.terracotta.statistics.derived.latency

Class LatencySimpleMovingAverage

java.lang.Object

org.terracotta.statistics.derived.latency.LatencySimpleMovingAverage

All Implemented Interfaces:

LatencyStatistic, ChainedEventObserver, ChainedObserver

public class LatencySimpleMovingAverage
extends java.lang.Object
implements ChainedEventObserver, LatencyStatistic

Field Summary

Fields

Modifier and Type	Field	Description
private java.util.concurrent.atomic.AtomicReference<LatencyPeriodAccumulator>	activePartition
private java.util.Queue<LatencyPeriodAccumulator>	archive
private static int	PARTITION_COUNT
private long	partitionSize
private long	windowSize

Constructor Summary

Constructors

Constructor	Description
LatencySimpleMovingAverage(long time, java.util.concurrent.TimeUnit unit)
LatencySimpleMovingAverage(long time, java.util.concurrent.TimeUnit unit, int partitionCount)

Method Summary

Modifier and Type	Method	Description
private void	archive(LatencyPeriodAccumulator partition)
double	average()
void	event(long timeNs, long latencyNs)	Called to indicate an event happened.
java.lang.Long	maximum()
java.lang.Long	minimum()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.terracotta.statistics.derived.latency.LatencyStatistic

averageStatistic, maximumStatistic, minimumStatistic

Field Detail

PARTITION_COUNT

private static final int PARTITION_COUNT

See Also:

Constant Field Values

archive

private final java.util.Queue<LatencyPeriodAccumulator> archive

activePartition

private final java.util.concurrent.atomic.AtomicReference<LatencyPeriodAccumulator> activePartition

windowSize

private final long windowSize

partitionSize

private final long partitionSize

Constructor Detail

LatencySimpleMovingAverage

public LatencySimpleMovingAverage(long time,
                                  java.util.concurrent.TimeUnit unit)

LatencySimpleMovingAverage

public LatencySimpleMovingAverage(long time,
                                  java.util.concurrent.TimeUnit unit,
                                  int partitionCount)

Method Detail

average

public final double average()

Specified by:

average in interface LatencyStatistic

Returns:

The average in ns or NaN if no value

maximum

public final java.lang.Long maximum()

Specified by:

maximum in interface LatencyStatistic

Returns:

The maximum in ns or null if it does not exist yet

minimum

public final java.lang.Long minimum()

Specified by:

minimum in interface LatencyStatistic

Returns:

The minimum in ns or null if it does not exist yet

event

public void event(long timeNs,
                  long latencyNs)

Description copied from interface: ChainedEventObserver

Called to indicate an event happened.

Specified by:

event in interface ChainedEventObserver

Parameters:

timeNs - the clock at event completion in ns

latencyNs - the event latency in ns

archive

private void archive(LatencyPeriodAccumulator partition)