Package org.apache.storm.loadgen
Class HttpForwardingMetricsServer
- java.lang.Object
-
- org.apache.storm.loadgen.HttpForwardingMetricsServer
-
- Direct Known Subclasses:
LoadMetricsServer
public abstract class HttpForwardingMetricsServer extends Object
A server that can listen for metrics from the HttpForwardingMetricsConsumer.
-
-
Constructor Summary
Constructors Constructor Description HttpForwardingMetricsServer(Map<String,Object> conf)Constructor.
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description intgetPort()StringgetUrl()abstract voidhandle(IMetricsConsumer.TaskInfo taskInfo, Collection<IMetricsConsumer.DataPoint> dataPoints, String topologyId)voidserve()voidserve(Integer port)Start the server.
-
-
-
Method Detail
-
handle
public abstract void handle(IMetricsConsumer.TaskInfo taskInfo, Collection<IMetricsConsumer.DataPoint> dataPoints, String topologyId)
-
serve
public void serve(Integer port)
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
public String getUrl()
-
-