EventRateSimpleMovingAverage

java.lang.Object
- org.terracotta.statistics.derived.EventRateSimpleMovingAverage

All Implemented Interfaces:: ChainedEventObserver, ChainedObserver, ValueStatistic<java.lang.Double>

public class EventRateSimpleMovingAverage
extends java.lang.Object
implements ChainedEventObserver, ValueStatistic<java.lang.Double>

Nested Class Summary

Nested Classes
Modifier and Type Class Description

(package private) static class EventRateSimpleMovingAverage.CounterPartition

Field Summary

Fields
Modifier and Type	Field	Description
`private java.util.concurrent.atomic.AtomicReference<EventRateSimpleMovingAverage.CounterPartition>`	`activePartition`
`private java.util.Queue<EventRateSimpleMovingAverage.CounterPartition>`	`archive`
`private static int`	`PARTITION_COUNT`
`private long`	`partitionSize`
`private long`	`windowSize`

Constructor Summary

Constructors
Constructor Description

EventRateSimpleMovingAverage(long time, java.util.concurrent.TimeUnit unit)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`private void`	`archive(EventRateSimpleMovingAverage.CounterPartition partition)`
`void`	`event(long time, long latency)`	Called to indicate an event happened.
`java.lang.Double`	`rate(java.util.concurrent.TimeUnit base)`
`java.lang.Double`	`rateUsingSeconds()`
`void`	`setWindow(long time, java.util.concurrent.TimeUnit unit)`
`StatisticType`	`type()`
`java.lang.Double`	`value()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

PARTITION_COUNT
```
private static final int PARTITION_COUNT
```
See Also:

Constant Field Values

archive

private final java.util.Queue<EventRateSimpleMovingAverage.CounterPartition> archive

activePartition

private final java.util.concurrent.atomic.AtomicReference<EventRateSimpleMovingAverage.CounterPartition> activePartition

windowSize
```
private volatile long windowSize
```

partitionSize
```
private volatile long partitionSize
```

Constructor Detail

EventRateSimpleMovingAverage

public EventRateSimpleMovingAverage(long time,
                                    java.util.concurrent.TimeUnit unit)

Method Detail
- setWindow
```
public void setWindow(long time,
                      java.util.concurrent.TimeUnit unit)
```
- value
```
public java.lang.Double value()
```
  Specified by:
  
  value in interface ValueStatistic<java.lang.Double>
  
  Returns:
  
  The current statistic value
- type
```
public StatisticType type()
```
  Specified by:
  
  type in interface ValueStatistic<java.lang.Double>
  
  Returns:
  
  The statistic type
- rateUsingSeconds
```
public java.lang.Double rateUsingSeconds()
```
- rate
```
public java.lang.Double rate(java.util.concurrent.TimeUnit base)
```
- 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
- archive
```
private void archive(EventRateSimpleMovingAverage.CounterPartition partition)
```