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 SummaryNested Classes
- 
Field SummaryFieldsModifier and TypeFieldDescriptionstatic final longstatic final long
- 
Method SummaryModifier 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.HttpForwardingMetricsServergetPort, getUrl, serve, serve
- 
Field Details- 
DEFAULT_REPORT_INTERVALpublic static final long DEFAULT_REPORT_INTERVAL- See Also:
 
- 
DEFAULT_WINDOW_INTERVALpublic static final long DEFAULT_WINDOW_INTERVAL- See Also:
 
 
- 
- 
Method Details- 
addCommandLineOptionspublic 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
 
- 
monitorForpublic 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 for
- client- the client to use when monitoring
- topoNames- the names of the topologies to monitor
- Throws:
- Exception- on any error
 
- 
handlepublic void handle(IMetricsConsumer.TaskInfo taskInfo, Collection<IMetricsConsumer.DataPoint> dataPoints, String topologyId) - Specified by:
- handlein class- HttpForwardingMetricsServer
 
 
-