Top Inners Fields Constructors Methods
org.terracotta.statistics.derived

public Class EventRateSimpleMovingAverage

extends Object
implements ChainedEventObserver, ValueStatistic<Double>
Class Inheritance
All Implemented Interfaces
org.terracotta.statistics.ValueStatistic, org.terracotta.statistics.observer.ChainedEventObserver, org.terracotta.statistics.observer.ChainedObserver
Imports
org.terracotta.statistics.StatisticType, .ValueStatistic, org.terracotta.statistics.observer.ChainedEventObserver, java.util.Iterator, .Queue, java.util.concurrent.ConcurrentLinkedQueue, .TimeUnit, java.util.concurrent.atomic.AtomicReference, .LongAdder
Author
cdennis

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
EventRateSimpleMovingAverage.CounterPartition

Field Summary

Modifier and TypeField and Description
private final AtomicReference<EventRateSimpleMovingAverage.CounterPartition>
activePartition

private final Queue<EventRateSimpleMovingAverage.CounterPartition>
archive

private static final int
PARTITION_COUNT

private volatile long
partitionSize

private volatile long
windowSize

Constructor Summary

AccessConstructor and Description
public
EventRateSimpleMovingAverage(long time, TimeUnit unit)

Method Summary

Modifier and TypeMethod and Description
private void
archive(EventRateSimpleMovingAverage.CounterPartition partition)

public void
event(long
the clock at event completion in ns
time, long
the event latency in ns
latency)

Implements org.terracotta.statistics.observer.ChainedEventObserver.event.

Called to indicate an event happened.
public Double
rate(TimeUnit base)

public Double
rateUsingSeconds()

public void
setWindow(long time, TimeUnit unit)

public StatisticType
type()

Implements org.terracotta.statistics.ValueStatistic.type.

public Double
value()

Implements org.terracotta.statistics.ValueStatistic.value.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

activePartitionback to summary
private final AtomicReference<EventRateSimpleMovingAverage.CounterPartition> activePartition
archiveback to summary
private final Queue<EventRateSimpleMovingAverage.CounterPartition> archive
PARTITION_COUNTback to summary
private static final int PARTITION_COUNT
partitionSizeback to summary
private volatile long partitionSize
windowSizeback to summary
private volatile long windowSize

Constructor Detail

EventRateSimpleMovingAverageback to summary
public EventRateSimpleMovingAverage(long time, TimeUnit unit)

Method Detail

archiveback to summary
private void archive(EventRateSimpleMovingAverage.CounterPartition partition)
eventback to summary
public void event(long time, long latency)

Implements org.terracotta.statistics.observer.ChainedEventObserver.event.

Doc from org.terracotta.statistics.observer.ChainedEventObserver.event.

Called to indicate an event happened.

Parameters
time:long

the clock at event completion in ns

latency:long

the event latency in ns

Annotations
@Override
rateback to summary
public Double rate(TimeUnit base)
rateUsingSecondsback to summary
public Double rateUsingSeconds()
setWindowback to summary
public void setWindow(long time, TimeUnit unit)
typeback to summary
public StatisticType type()

Implements org.terracotta.statistics.ValueStatistic.type.

Returns:StatisticType

Doc from org.terracotta.statistics.ValueStatistic.type.

The statistic type

Annotations
@Override
valueback to summary
public Double value()

Implements org.terracotta.statistics.ValueStatistic.value.

Returns:Double

Doc from org.terracotta.statistics.ValueStatistic.value.

The current statistic value

Annotations
@Override
org.terracotta.statistics.derived back to summary

pack-priv Class EventRateSimpleMovingAverage.CounterPartition

extends LongAdder
Class Inheritance

Field Summary

Modifier and TypeField and Description
private final long
end

private static final long
serialVersionUID

Hides java.util.concurrent.atomic.LongAdder.serialVersionUID.

private final long
start

Constructor Summary

AccessConstructor and Description
pack-priv
CounterPartition(long start, long length)

Method Summary

Modifier and TypeMethod and Description
public long
end()

public boolean
isBefore(long time)

public long
start()

public boolean
targetFor(long time)

Inherited from java.util.concurrent.atomic.LongAdder:
adddecrementdoubleValuefloatValueincrementintValuelongValueresetsumsumThenResettoString

Field Detail

endback to summary
private final long end
serialVersionUIDback to summary
private static final long serialVersionUID

Hides java.util.concurrent.atomic.LongAdder.serialVersionUID.

startback to summary
private final long start

Constructor Detail

CounterPartitionback to summary
pack-priv CounterPartition(long start, long length)

Method Detail

endback to summary
public long end()
isBeforeback to summary
public boolean isBefore(long time)
startback to summary
public long start()
targetForback to summary
public boolean targetFor(long time)