Package org.terracotta.statistics.derived.latency

Class LatencyAccumulator

java.lang.Object

org.terracotta.statistics.derived.latency.LatencyAccumulator

All Implemented Interfaces:

LatencyStatistic, ChainedEventObserver, ChainedObserver

public class LatencyAccumulator
extends Object
implements LatencyStatistic, ChainedEventObserver

This accumulator accumulate latency metrics. It is lock-free so when computing some values,it is possible that a thread is writing some values while the snapshot is being computed. So there is the possibility of an error in the result.

Field Summary

Fields

Modifier and Type	Field	Description
private final LongAdder	count
private static final long	DEFAULT_MAX
private static final long	DEFAULT_MIN
private final LongAccumulator	maximum
private final LongAccumulator	minimum
private final LongAdder	total

Constructor Summary

Constructors

Modifier	Constructor	Description
private	LatencyAccumulator(long... latencies)

Method Summary

Modifier and Type	Method	Description
void	accumulate(long latency)
void	accumulate(LatencyAccumulator accumulator)
static LatencyAccumulator	accumulator(long... latencies)
double	average()
long	count()
static LatencyAccumulator	empty()
void	event(long time, long latency)	Called to indicate an event happened.
boolean	isEmpty()
Long	maximum()
Long	minimum()
String	toString()
long	total()

Methods inherited from class java.lang.Object

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

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

averageStatistic, maximumStatistic, minimumStatistic

Field Details

DEFAULT_MIN

private static final long DEFAULT_MIN

See Also:

• Constant Field Values

DEFAULT_MAX

private static final long DEFAULT_MAX

See Also:

• Constant Field Values

count

private final LongAdder count

total

private final LongAdder total

minimum

private final LongAccumulator minimum

maximum

private final LongAccumulator maximum

Constructor Details

LatencyAccumulator

private LatencyAccumulator(long... latencies)

Method Details

accumulate

public void accumulate(long latency)

accumulate

public void accumulate(LatencyAccumulator accumulator)

count

public long count()

total

public long total()

isEmpty

public boolean isEmpty()

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

maximum

public Long maximum()

Specified by:

maximum in interface LatencyStatistic

Returns:

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

minimum

public Long minimum()

Specified by:

minimum in interface LatencyStatistic

Returns:

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

average

public double average()

Specified by:

average in interface LatencyStatistic

Returns:

The average in ns or NaN if no value

toString

public String toString()

Overrides:

toString in class Object

accumulator

public static LatencyAccumulator accumulator(long... latencies)

empty

public static LatencyAccumulator empty()