Class TimedCircuitStats

java.lang.Object

dev.failsafe.internal.TimedCircuitStats

All Implemented Interfaces:

CircuitStats

class TimedCircuitStats
extends Object
implements CircuitStats

A CircuitStats implementation that counts execution results within a time period, and buckets results to minimize overhead.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	TimedCircuitStats.Bucket
(package private) static class	TimedCircuitStats.Clock
(package private) static class	TimedCircuitStats.Stat

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final TimedCircuitStats.Bucket[]	buckets
private final long	bucketSizeMillis
private final TimedCircuitStats.Clock	clock
(package private) int	currentIndex
(package private) static final int	DEFAULT_BUCKET_COUNT
private final TimedCircuitStats.Stat	summary
private final long	windowSizeMillis

Constructor Summary

Constructors

Constructor	Description
TimedCircuitStats(int bucketCount, Duration thresholdingPeriod, TimedCircuitStats.Clock clock, CircuitStats oldStats)

Method Summary

Modifier and Type	Method	Description
(package private) void	copyStats(CircuitStats oldStats)	Copies the most recent stats from the oldStats into this in order from oldest to newest and orders buckets from oldest to newest, with uninitialized buckets counting as oldest.
(package private) TimedCircuitStats.Bucket	getCurrentBucket()	Returns the current bucket based on the current time, moving the internal storage to the current bucket if necessary, resetting bucket stats along the way.
int	getExecutionCount()
int	getFailureCount()
int	getFailureRate()
int	getSuccessCount()
int	getSuccessRate()
private int	indexAfter(int index)	Returns the index after the index.
private int	indexBefore(int index)	Returns the index before the index.
private int	nextIndex()	Returns the next index.
void	recordFailure()
void	recordSuccess()
void	reset()
String	toString()

Methods inherited from class Object

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

Methods inherited from interface CircuitStats

copyExecutions

Field Details

DEFAULT_BUCKET_COUNT

static final int DEFAULT_BUCKET_COUNT

See Also:

• Constant Field Values

clock

private final TimedCircuitStats.Clock clock

bucketSizeMillis

private final long bucketSizeMillis

windowSizeMillis

private final long windowSizeMillis

buckets

final TimedCircuitStats.Bucket[] buckets

summary

private final TimedCircuitStats.Stat summary

currentIndex

volatile int currentIndex

Constructor Details

TimedCircuitStats

public TimedCircuitStats(int bucketCount,
 Duration thresholdingPeriod,
 TimedCircuitStats.Clock clock,
 CircuitStats oldStats)

Method Details

copyStats

void copyStats(CircuitStats oldStats)

Copies the most recent stats from the oldStats into this in order from oldest to newest and orders buckets from oldest to newest, with uninitialized buckets counting as oldest.

recordSuccess

public void recordSuccess()

Specified by:

recordSuccess in interface CircuitStats

recordFailure

public void recordFailure()

Specified by:

recordFailure in interface CircuitStats

getExecutionCount

public int getExecutionCount()

Specified by:

getExecutionCount in interface CircuitStats

getFailureCount

public int getFailureCount()

Specified by:

getFailureCount in interface CircuitStats

getFailureRate

public int getFailureRate()

Specified by:

getFailureRate in interface CircuitStats

getSuccessCount

public int getSuccessCount()

Specified by:

getSuccessCount in interface CircuitStats

getSuccessRate

public int getSuccessRate()

Specified by:

getSuccessRate in interface CircuitStats

reset

public void reset()

Specified by:

reset in interface CircuitStats

getCurrentBucket

TimedCircuitStats.Bucket getCurrentBucket()

Returns the current bucket based on the current time, moving the internal storage to the current bucket if necessary, resetting bucket stats along the way.

nextIndex

private int nextIndex()

Returns the next index.

indexAfter

private int indexAfter(int index)

Returns the index after the index.

indexBefore

private int indexBefore(int index)

Returns the index before the index.

toString

public String toString()

Overrides:

toString in class Object