Package org.glassfish.jersey.server.internal.monitoring

Class AggregatedSlidingWindowTimeReservoir

java.lang.Object

org.glassfish.jersey.server.internal.monitoring.core.AbstractSlidingWindowTimeReservoir<AggregatedValueObject>

org.glassfish.jersey.server.internal.monitoring.AggregatedSlidingWindowTimeReservoir

All Implemented Interfaces:

TimeReservoir<AggregatedValueObject>

class AggregatedSlidingWindowTimeReservoir
extends AbstractSlidingWindowTimeReservoir<AggregatedValueObject>

Aggregated sliding window time reservoir stores aggregated measurements in a time window of given size. The resulting snapshot provides precise data as far as the granularity of aggregating trimmer is not concerned. The granularity of the trimmer determines the granularity of the data the snapshot provides. In other words, the aggregated value object is either included in the resulting measurements or not depending whether it was trimmed or not.

Field Summary

Fields

Modifier and Type	Field	Description
private AggregatingTrimmer	notifier

Constructor Summary

Constructors

Constructor	Description
AggregatedSlidingWindowTimeReservoir(long window, java.util.concurrent.TimeUnit windowUnit, long startTime, java.util.concurrent.TimeUnit startTimeUnit, AggregatingTrimmer notifier)	Creates an aggregated sliding window reservoir.

Method Summary

Modifier and Type	Method	Description
protected UniformTimeSnapshot	snapshot(java.util.Collection<AggregatedValueObject> values, long timeInterval, java.util.concurrent.TimeUnit timeIntervalUnit, long time, java.util.concurrent.TimeUnit timeUnit)	Subclasses are required to instantiate UniformTimeSnapshot on their own.

Methods inherited from class org.glassfish.jersey.server.internal.monitoring.core.AbstractSlidingWindowTimeReservoir

getSnapshot, interval, size, update

Methods inherited from class java.lang.Object

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

Field Detail

notifier

private final AggregatingTrimmer notifier

Constructor Detail

AggregatedSlidingWindowTimeReservoir

public AggregatedSlidingWindowTimeReservoir(long window,
                                            java.util.concurrent.TimeUnit windowUnit,
                                            long startTime,
                                            java.util.concurrent.TimeUnit startTimeUnit,
                                            AggregatingTrimmer notifier)

Creates an aggregated sliding window reservoir.

Parameters:

window - The time size of the window

windowUnit - The unit of the window size

startTime - The start time from when to calculate the statistics

startTimeUnit - The unit of the start time

notifier - The aggregating trimmer that produces the aggregated data

Method Detail

snapshot

protected UniformTimeSnapshot snapshot(java.util.Collection<AggregatedValueObject> values,
                                       long timeInterval,
                                       java.util.concurrent.TimeUnit timeIntervalUnit,
                                       long time,
                                       java.util.concurrent.TimeUnit timeUnit)

Description copied from class: AbstractSlidingWindowTimeReservoir

Subclasses are required to instantiate UniformTimeSnapshot on their own.

Specified by:

snapshot in class AbstractSlidingWindowTimeReservoir<AggregatedValueObject>

Parameters:

values - The values to create the snapshot from

timeInterval - The time interval this snapshot conforms to

timeIntervalUnit - The interval unit of the time interval

time - The time of the request of the snapshot

timeUnit - The unit of the time of the snapshot request

Returns:

The snapshot