Package org.apache.storm.loadgen
Class LoadMetricsServer
java.lang.Object
org.apache.storm.loadgen.HttpForwardingMetricsServer
org.apache.storm.loadgen.LoadMetricsServer
A metrics server that records and reports metrics for a set of running topologies.
-
Nested Class Summary
Nested Classes -
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final longstatic final long -
Method Summary
Modifier and TypeMethodDescriptionstatic voidaddCommandLineOptions(org.apache.commons.cli.Options options) Add Command line options for configuring the output of this.voidhandle(IMetricsConsumer.TaskInfo taskInfo, Collection<IMetricsConsumer.DataPoint> dataPoints, String topologyId) voidmonitorFor(double execTimeMins, Nimbus.Iface client, Collection<String> topoNames) Monitor the list of topologies for the given time frame.Methods inherited from class org.apache.storm.loadgen.HttpForwardingMetricsServer
getPort, getUrl, serve, serve
-
Field Details
-
DEFAULT_REPORT_INTERVAL
public static final long DEFAULT_REPORT_INTERVAL- See Also:
-
DEFAULT_WINDOW_INTERVAL
public static final long DEFAULT_WINDOW_INTERVAL- See Also:
-
-
Method Details
-
addCommandLineOptions
public static void addCommandLineOptions(org.apache.commons.cli.Options options) Add Command line options for configuring the output of this.- Parameters:
options- command line options to update
-
monitorFor
public void monitorFor(double execTimeMins, Nimbus.Iface client, Collection<String> topoNames) throws Exception Monitor the list of topologies for the given time frame.- Parameters:
execTimeMins- how long to monitor forclient- the client to use when monitoringtopoNames- the names of the topologies to monitor- Throws:
Exception- on any error
-
handle
public void handle(IMetricsConsumer.TaskInfo taskInfo, Collection<IMetricsConsumer.DataPoint> dataPoints, String topologyId) - Specified by:
handlein classHttpForwardingMetricsServer
-