public class MonitoringThroughputFilter extends AbstractFilterPlugin
IPlugin.PluginInputPortReference, IPlugin.STATE
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
CONFIG_PROPERTY_NAME_INTERVAL_SIZE
The name of the property determining the interval size.
|
static java.lang.String |
CONFIG_PROPERTY_NAME_TIMEUNIT
The name of the property determining the time unit.
|
static java.lang.String |
CONFIG_PROPERTY_VALUE_INTERVAL_SIZE_ONE_SECOND
The configuration property value for
CONFIG_PROPERTY_NAME_INTERVAL_SIZE , leading to a bin size of 1
second. |
static java.lang.String |
CONFIG_PROPERTY_VALUE_TIMEUNIT
The default value of the time unit property (nanoseconds).
|
static java.lang.String |
INPUT_PORT_NAME_RECORDS
The name of the input port receiving other objects.
|
static java.lang.String |
OUTPUT_PORT_NAME_RELAYED_RECORDS
The name of the output port delivering the received objects.
|
static java.lang.String |
OUTPUT_PORT_NAME_THROUGHPUT
The name of the output port delivering calculated throughput.
|
static java.lang.String |
OUTPUT_PORT_NAME_UNCOUNTED_RECORDS
The name of the output port delivering the uncounted objects.
|
CONFIG_NAME, configuration, logger, projectContext, recordsTimeUnitFromProjectContext
Constructor and Description |
---|
MonitoringThroughputFilter(Configuration configuration,
IProjectContext projectContext) |
Modifier and Type | Method and Description |
---|---|
Configuration |
getCurrentConfiguration()
This method should deliver a
Configuration object containing the current configuration of this instance. |
void |
inputRecord(IMonitoringRecord record) |
init, terminate
areAllRepositoryPortsConnected, connect, connect, deliver, getAllDisplayNames, getAllInputPortNames, getAllOutputPortNames, getAllRepositoryPortNames, getConnectedPlugins, getCurrentRepositories, getDefaultConfiguration, getIncomingPlugins, getPluginDescription, getPluginName, getRepository, getState, isConnectionAllowed, notifyNewIncomingConnection, notifyNewOutgoingConnection, shutdown, start
getName
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
connect, getAllDisplayNames, getAllInputPortNames, getAllOutputPortNames, getAllRepositoryPortNames, getConnectedPlugins, getCurrentRepositories, getName, getPluginDescription, getPluginName, getState
public static final java.lang.String INPUT_PORT_NAME_RECORDS
public static final java.lang.String OUTPUT_PORT_NAME_RELAYED_RECORDS
public static final java.lang.String OUTPUT_PORT_NAME_UNCOUNTED_RECORDS
public static final java.lang.String OUTPUT_PORT_NAME_THROUGHPUT
public static final java.lang.String CONFIG_PROPERTY_NAME_TIMEUNIT
public static final java.lang.String CONFIG_PROPERTY_VALUE_TIMEUNIT
public static final java.lang.String CONFIG_PROPERTY_NAME_INTERVAL_SIZE
public static final java.lang.String CONFIG_PROPERTY_VALUE_INTERVAL_SIZE_ONE_SECOND
CONFIG_PROPERTY_NAME_INTERVAL_SIZE
, leading to a bin size of 1
second.public MonitoringThroughputFilter(Configuration configuration, IProjectContext projectContext)
public Configuration getCurrentConfiguration()
AbstractAnalysisComponent
Configuration
object containing the current configuration of this instance. In other words: The constructor should be
able to use the given object to initialize a new instance of this class with the same intern properties.getCurrentConfiguration
in interface IAnalysisComponent
getCurrentConfiguration
in interface IPlugin
getCurrentConfiguration
in class AbstractAnalysisComponent
public final void inputRecord(IMonitoringRecord record)
Copyright 2020 Kieker Project, http://kieker-monitoring.net