Package org.terracotta.statistics.derived

Class EventRateSimpleMovingAverage

java.lang.Object

org.terracotta.statistics.derived.EventRateSimpleMovingAverage

All Implemented Interfaces:

ChainedEventObserver, ChainedObserver, ValueStatistic<Double>

public class EventRateSimpleMovingAverage
extends Object
implements ChainedEventObserver, ValueStatistic<Double>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	EventRateSimpleMovingAverage.CounterPartition

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
EventRateSimpleMovingAverage(long time, TimeUnit unit)

Method Summary

Modifier and Type	Method	Description
private void	archive(EventRateSimpleMovingAverage.CounterPartition partition)
void	event(long time, long latency)	Called to indicate an event happened.
Double	rate(TimeUnit base)
Double	rateUsingSeconds()
void	setWindow(long time, TimeUnit unit)
StatisticType	type()
Double	value()

Methods inherited from class java.lang.Object

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

Field Details

PARTITION_COUNT

private static final int PARTITION_COUNT

See Also:

• Constant Field Values

archive

private final Queue<EventRateSimpleMovingAverage.CounterPartition> archive

activePartition

private final AtomicReference<EventRateSimpleMovingAverage.CounterPartition> activePartition

windowSize

private volatile long windowSize

partitionSize

private volatile long partitionSize

Constructor Details

EventRateSimpleMovingAverage

public EventRateSimpleMovingAverage(long time,
 TimeUnit unit)

Method Details

setWindow

public void setWindow(long time,
 TimeUnit unit)

value

public Double value()

Specified by:

value in interface ValueStatistic<Double>

Returns:

The current statistic value

type

public StatisticType type()

Specified by:

type in interface ValueStatistic<Double>

Returns:

The statistic type

rateUsingSeconds

public Double rateUsingSeconds()

rate

public Double rate(TimeUnit base)

event

public void event(long time,
 long latency)

Description copied from interface: ChainedEventObserver

Called to indicate an event happened.

Specified by:

event in interface ChainedEventObserver

Parameters:

time - the clock at event completion in ns

latency - the event latency in ns

archive

private void archive(EventRateSimpleMovingAverage.CounterPartition partition)