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 SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionintgetPort()getUrl()abstract voidhandle(IMetricsConsumer.TaskInfo taskInfo, Collection<IMetricsConsumer.DataPoint> dataPoints, String topologyId) voidserve()voidStart the server.
- 
Constructor Details- 
HttpForwardingMetricsServerConstructor.- Parameters:
- conf- the configuration for storm.
 
 
- 
- 
Method Details- 
handlepublic abstract void handle(IMetricsConsumer.TaskInfo taskInfo, Collection<IMetricsConsumer.DataPoint> dataPoints, String topologyId) 
- 
serveStart the server.- Parameters:
- port- the port it shuld listen on, or null/<= 0 to pick a free ephemeral port.
 
- 
servepublic void serve()
- 
getPortpublic int getPort()
- 
getUrl
 
-