public class MonitoringThroughputFilter extends teetime.framework.AbstractConsumerStage<IMonitoringRecord>
Constructor and Description |
---|
MonitoringThroughputFilter(long intervalSize)
Creates a new instance of this class using the given parameters.
|
Modifier and Type | Method and Description |
---|---|
protected void |
execute(IMonitoringRecord record) |
teetime.framework.OutputPort<IMonitoringRecord> |
getRelayedRecordsOutputPort() |
teetime.framework.OutputPort<java.lang.Long> |
getThroughputOutputPort() |
teetime.framework.OutputPort<IMonitoringRecord> |
getUncountedRecordsOutputPort() |
createInputPort, execute, getInputPort
abort, addInputPortRemovedListener, addOutputPortRemovedListener, compareAndSetBeingExecuted, createInputPort, createInputPort, createInputPort, createOutputPort, createOutputPort, createOutputPort, createOutputPort, declareActive, declarePassive, executeByFramework, getCurrentState, getId, getInputPorts, getOutputPorts, getOwningThread, getTerminationStrategy, isActive, isBeingExecuted, isPaused, isProducer, isStateless, onSignal, onStarting, onTerminating, onValidating, removeDynamicPort, removeDynamicPort, setPaused, setStateless, shouldBeTerminated, signalAlreadyReceived, terminateStage, toString, workCompleted
public MonitoringThroughputFilter(long intervalSize)
intervalSize
- Determines the interval size. Choose a proper time unit.protected void execute(IMonitoringRecord record)
execute
in class teetime.framework.AbstractConsumerStage<IMonitoringRecord>
public teetime.framework.OutputPort<IMonitoringRecord> getUncountedRecordsOutputPort()
public teetime.framework.OutputPort<java.lang.Long> getThroughputOutputPort()
public teetime.framework.OutputPort<IMonitoringRecord> getRelayedRecordsOutputPort()
Copyright 2020 Kieker Project, http://kieker-monitoring.net