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 Object
implements ChainedEventObserver, LatencyStatistic

Field Summary

Fields

Modifier and Type	Field	Description
private final AtomicReference<LatencyPeriodAccumulator>	activePartition
private final Queue<LatencyPeriodAccumulator>	archive
private static final int	PARTITION_COUNT
private final long	partitionSize
private final long	windowSize

Constructor Summary

Constructors

Constructor	Description
LatencySimpleMovingAverage(long time, TimeUnit unit)
LatencySimpleMovingAverage(long time, TimeUnit unit, int partitionCount)

Method Summary

Modifier and Type	Method	Description
private void	archive(LatencyPeriodAccumulator partition)
final double	average()
void	event(long timeNs, long latencyNs)	Called to indicate an event happened.
final Long	maximum()
final 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 Details

PARTITION_COUNT

private static final int PARTITION_COUNT

See Also:

• Constant Field Values

archive

private final Queue<LatencyPeriodAccumulator> archive

activePartition

private final AtomicReference<LatencyPeriodAccumulator> activePartition

windowSize

private final long windowSize

partitionSize

private final long partitionSize

Constructor Details

LatencySimpleMovingAverage

public LatencySimpleMovingAverage(long time,
 TimeUnit unit)

LatencySimpleMovingAverage

public LatencySimpleMovingAverage(long time,
 TimeUnit unit,
 int partitionCount)

Method Details

average

public final double average()

Specified by:

average in interface LatencyStatistic

Returns:

The average in ns or NaN if no value

maximum

public final Long maximum()

Specified by:

maximum in interface LatencyStatistic

Returns:

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

minimum

public final 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)