org.apache.storm.metric

Class HttpForwardingMetricsServer

java.lang.Object

org.apache.storm.metric.HttpForwardingMetricsServer

public abstract class HttpForwardingMetricsServer
extends Object

A server that can listen for metrics from the HttpForwardingMetricsConsumer.

Constructor Summary

Constructors

Constructor and Description
HttpForwardingMetricsServer(Map conf)

Method Summary

Modifier and Type	Method and Description
int	getPort()
String	getUrl()
abstract void	handle(IMetricsConsumer.TaskInfo taskInfo, Collection<IMetricsConsumer.DataPoint> dataPoints)
void	serve()
void	serve(Integer port)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HttpForwardingMetricsServer

public HttpForwardingMetricsServer(Map conf)

Method Detail

handle

public abstract void handle(IMetricsConsumer.TaskInfo taskInfo,
                            Collection<IMetricsConsumer.DataPoint> dataPoints)

serve

public void serve(Integer port)

serve

public void serve()

getPort

public int getPort()

getUrl

public String getUrl()