com.neeve.stats

Class Stats.LatencyManager

java.lang.Object

com.neeve.stats.Stats.LatencyManager

All Implemented Interfaces:

IStats.Latencies, IStats.Series

Enclosing class:

Stats

public static final class Stats.LatencyManager
extends Object
implements IStats.Latencies

Class used to hold and compute and retrieve latencies statistics.

Nested Class Summary

Nested classes/interfaces inherited from interface com.neeve.stats.IStats.Series

IStats.Series.Collector, IStats.Series.Type

Field Summary

Fields inherited from interface com.neeve.stats.IStats.Latencies

PROP_LATENCY_MANAGER_SAMPLE_SIZE

Fields inherited from interface com.neeve.stats.IStats.Series

PROP_SERIES_SAMPLE_SIZE, PROP_SERIES_SAMPLE_SIZE_DEFAULT

Constructor Summary

Constructors

Constructor and Description
LatencyManager(String name) Construct using name to describe the latencies stored
LatencyManager(String name, int sampleSize) Construct using name to describe the latencies stored

Method Summary

Modifier and Type	Method and Description
long	add(double val) Implementation of IStats.Series.add(double)
void	compute() Compute latency statistics.
void	compute(double multiplier) Compute latency statistics.
long	count() Get the number of latency entries added so far
long	get(IStats.Series.Collector collector, cern.colt.list.DoubleArrayList temp, long minSeqNo) Implementation of IStats.Latencies#get(Collector, DoubleArrayList, long}
void	get(StringBuilder sb) Format stats for output
void	get(StringBuilder sb, boolean csv) Format stats for output
void	get(StringBuilder sb, NumberFormat format) Implementation of IStats.Latencies#get(StringBuilder, NumberFormat}
String	getName() Implementation of IStats.Series.getName()
XString	getNameAsRaw() Implementation of IStats.Series.getNameAsRaw()
IStats.Series.Type	getType() Implementation of IStats.Series.getType()
double	max() Implementation of IStats.Series.max()
double	mean() Implementation of IStats.Series.mean()
double	median() Implementation of IStats.Series.median()
double	min() Implementation of IStats.Series.min()
double	pct75() Implementation of IStats.Series.pct75()
double	pct90() Implementation of IStats.Series.pct90()
double	pct99() Implementation of IStats.Series.pct99()
double	pct999() Implementation of IStats.Series.pct999()
double	pct9999() Implementation of IStats.Series.pct9999()
void	reset() Implementation of IStats.Series.reset()
long	sample() Implementation of IStats.Series.sample()
long	sequenceNumber() Implementation of IStats.Series.sequenceNumber()
int	size() Implementation of IStats.Series.size()

Methods inherited from class java.lang.Object

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

Constructor Detail

LatencyManager

public LatencyManager(String name)

Construct using name to describe the latencies stored

LatencyManager

public LatencyManager(String name,
                      int sampleSize)

Construct using name to describe the latencies stored

Method Detail

compute

public final void compute()

Compute latency statistics.

Specified by:

compute in interface IStats.Series

compute

public final void compute(double multiplier)

Compute latency statistics.

count

public final long count()

Get the number of latency entries added so far

get

public final void get(StringBuilder sb,
                      boolean csv)

Format stats for output

get

public final void get(StringBuilder sb)

Format stats for output

getName

public final String getName()

Implementation of IStats.Series.getName()

Specified by:

getName in interface IStats.Series

Returns:

The statistic name

getNameAsRaw

public final XString getNameAsRaw()

Implementation of IStats.Series.getNameAsRaw()

Specified by:

getNameAsRaw in interface IStats.Series

Returns:

The statistic name in raw form

getType

public final IStats.Series.Type getType()

Implementation of IStats.Series.getType()

Specified by:

getType in interface IStats.Series

Returns:

The IStats.Series's IStats.Series.Type.

size

public final int size()

Implementation of IStats.Series.size()

Specified by:

size in interface IStats.Series

Returns:

The number of historic data points this series can retain before older values are discarded.

add

public final long add(double val)

Implementation of IStats.Series.add(double)

Specified by:

add in interface IStats.Series

Parameters:

val - the sampled value to record.

Returns:

the sequence number of the element added.

sequenceNumber

public final long sequenceNumber()

Implementation of IStats.Series.sequenceNumber()

Specified by:

sequenceNumber in interface IStats.Series

sample

public final long sample()

Implementation of IStats.Series.sample()

Specified by:

sample in interface IStats.Series

Returns:

The number of samples over which the current values have been computed.

min

public final double min()

Implementation of IStats.Series.min()

Specified by:

min in interface IStats.Series

Returns:

the minimum value captured.

max

public final double max()

Implementation of IStats.Series.max()

Specified by:

max in interface IStats.Series

Returns:

the maximum value captured.

mean

public final double mean()

Implementation of IStats.Series.mean()

Specified by:

mean in interface IStats.Series

Returns:

the mean value.

median

public final double median()

Implementation of IStats.Series.median()

Specified by:

median in interface IStats.Series

Returns:

the median latency.

pct75

public final double pct75()

Implementation of IStats.Series.pct75()

Specified by:

pct75 in interface IStats.Series

Returns:

the 75 percentile value.

pct90

public final double pct90()

Implementation of IStats.Series.pct90()

Specified by:

pct90 in interface IStats.Series

Returns:

the 90 percentile value.

pct99

public final double pct99()

Implementation of IStats.Series.pct99()

Specified by:

pct99 in interface IStats.Series

Returns:

the 99 percentile value.

pct999

public final double pct999()

Implementation of IStats.Series.pct999()

Specified by:

pct999 in interface IStats.Series

Returns:

the 99.9 percentile value.

pct9999

public final double pct9999()

Implementation of IStats.Series.pct9999()

Specified by:

pct9999 in interface IStats.Series

Returns:

the 99.99 percentile value.

get

public final void get(StringBuilder sb,
                      NumberFormat format)

Implementation of IStats.Latencies#get(StringBuilder, NumberFormat}

Specified by:

get in interface IStats.Series

get

public long get(IStats.Series.Collector collector,
                cern.colt.list.DoubleArrayList temp,
                long minSeqNo)

Implementation of IStats.Latencies#get(Collector, DoubleArrayList, long}

Specified by:

get in interface IStats.Series

Parameters:

collector - The collector to which values will be collected via IStats.Series.Collector.add(long, double)

temp - A temporary list into which collected values will be copied.

minSeqNo - The minimum sequence number (inclusive) to collect.

Returns:

the sequence number of the first element reported or -1 if minSequenceNumber is greater than the current series sequence number

reset

public final void reset()

Implementation of IStats.Series.reset()

Specified by:

reset in interface IStats.Series