Package org.apache.storm.loadgen
Class HttpForwardingMetricsServer
java.lang.Object
org.apache.storm.loadgen.HttpForwardingMetricsServer
- Direct Known Subclasses:
LoadMetricsServer
A server that can listen for metrics from the HttpForwardingMetricsConsumer.
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionint
getPort()
getUrl()
abstract void
handle
(IMetricsConsumer.TaskInfo taskInfo, Collection<IMetricsConsumer.DataPoint> dataPoints, String topologyId) void
serve()
void
Start the server.
-
Constructor Details
-
HttpForwardingMetricsServer
Constructor.- Parameters:
conf
- the configuration for storm.
-
-
Method Details
-
handle
public abstract void handle(IMetricsConsumer.TaskInfo taskInfo, Collection<IMetricsConsumer.DataPoint> dataPoints, String topologyId) -
serve
Start the server.- Parameters:
port
- the port it shuld listen on, or null/<= 0 to pick a free ephemeral port.
-
serve
public void serve() -
getPort
public int getPort() -
getUrl
-