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

public Class LatencySimpleMovingAverage

extends Object
implements ChainedEventObserver, LatencyStatistic
Class Inheritance
All Implemented Interfaces
org.terracotta.statistics.derived.latency.LatencyStatistic, org.terracotta.statistics.observer.ChainedEventObserver, org.terracotta.statistics.observer.ChainedObserver
Imports
org.terracotta.statistics.observer.ChainedEventObserver, java.util.Iterator, .Queue, java.util.concurrent.ConcurrentLinkedQueue, .TimeUnit, java.util.concurrent.atomic.AtomicReference
Authors
cdennis, Mathieu Carbou

Field Summary

Modifier and TypeField and 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

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

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

Method Summary

Modifier and TypeMethod and Description
private void
archive(LatencyPeriodAccumulator partition)

public final double
average()

Implements org.terracotta.statistics.derived.latency.LatencyStatistic.average.

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

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

Called to indicate an event happened.
public final Long
maximum()

Implements org.terracotta.statistics.derived.latency.LatencyStatistic.maximum.

public final Long
minimum()

Implements org.terracotta.statistics.derived.latency.LatencyStatistic.minimum.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

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

Constructor Detail

LatencySimpleMovingAverageback to summary
public LatencySimpleMovingAverage(long time, TimeUnit unit)
LatencySimpleMovingAverageback to summary
public LatencySimpleMovingAverage(long time, TimeUnit unit, int partitionCount)

Method Detail

archiveback to summary
private void archive(LatencyPeriodAccumulator partition)
averageback to summary
public final double average()

Implements org.terracotta.statistics.derived.latency.LatencyStatistic.average.

Returns:double

Doc from org.terracotta.statistics.derived.latency.LatencyStatistic.average.

The average in ns or NaN if no value

Annotations
@Override
eventback to summary
public void event(long timeNs, long latencyNs)

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

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

Called to indicate an event happened.

Parameters
timeNs:long

the clock at event completion in ns

latencyNs:long

the event latency in ns

Annotations
@Override
maximumback to summary
public final Long maximum()

Implements org.terracotta.statistics.derived.latency.LatencyStatistic.maximum.

Returns:Long

Doc from org.terracotta.statistics.derived.latency.LatencyStatistic.maximum.

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

Annotations
@Override
minimumback to summary
public final Long minimum()

Implements org.terracotta.statistics.derived.latency.LatencyStatistic.minimum.

Returns:Long

Doc from org.terracotta.statistics.derived.latency.LatencyStatistic.minimum.

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

Annotations
@Override