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
-
Field Summary
Modifier and TypeFieldDescriptionstatic final long
static final long
-
Method Summary
Modifier and TypeMethodDescriptionstatic void
addCommandLineOptions
(org.apache.commons.cli.Options options) Add Command line options for configuring the output of this.void
handle
(IMetricsConsumer.TaskInfo taskInfo, Collection<IMetricsConsumer.DataPoint> dataPoints, String topologyId) void
monitorFor
(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:
handle
in classHttpForwardingMetricsServer
-