public class RealtimeRecordDelayFilter
extends teetime.framework.CompositeStage
IMonitoringRecord
s with delays computed from the IMonitoringRecord.getLoggingTimestamp()
value
(assumed to be in the configured resolution). For example, after initialization, if records with logging timestamps 3000 and 4500 nanos are received, the
first record is forwarded immediately; the second will be forwarded 1500 nanos later. The acceleration factor can be used to accelerate/slow down the
replay (default 1.0, which means no acceleration/slow down).Constructor and Description |
---|
RealtimeRecordDelayFilter(java.util.concurrent.TimeUnit timeunit,
double accelerationFactor)
Creates a new instance of this class using the given parameters.
|
Modifier and Type | Method and Description |
---|---|
teetime.framework.InputPort<IMonitoringRecord> |
getInputPort() |
long |
getNegativeDelayWarningBound()
Returns the time bound for which a warning is displayed when the computed delay falls below -(time bound).
|
teetime.framework.OutputPort<IMonitoringRecord> |
getOutputPort() |
void |
setNegativeDelayWarningBound(long negativeDelay,
java.util.concurrent.TimeUnit unit)
Sets the time bound for which a warning is displayed when the computed delay falls below -(time bound).
|
public RealtimeRecordDelayFilter(java.util.concurrent.TimeUnit timeunit, double accelerationFactor)
timeunit
- The time unit to be used.accelerationFactor
- Determines the replay speed.public long getNegativeDelayWarningBound()
public void setNegativeDelayWarningBound(long negativeDelay, java.util.concurrent.TimeUnit unit)
negativeDelay
- The chosen time bound.unit
- Time unit of the chosen time bound.public teetime.framework.InputPort<IMonitoringRecord> getInputPort()
public teetime.framework.OutputPort<IMonitoringRecord> getOutputPort()
Copyright 2021 Kieker Project, http://kieker-monitoring.net